[feat] Adjusted several default parameters and descriptions in the Loader, and refactored the failure-handling logic for batch inserts.

kenssa4eedfd · kenssa4eedfd · commit e39f5036b75b · 2026-01-19T10:10:14.000+08:00
diff --git a/hugegraph-loader/src/main/java/org/apache/hugegraph/loader/task/TaskManager.java b/hugegraph-loader/src/main/java/org/apache/hugegraph/loader/task/TaskManager.java
@@ -162,12 +162,13 @@ public void submitBatch(InputStruct struct, ElementMapping mapping,
                                  mapping.type(), e);
                         this.submitInSingle(struct, mapping, batch);
                     } else {
-                        summary.metrics(struct).minusFlighting(batch.size());
                         this.context.occurredError();
                         this.context.stopLoading();
                         Printer.printError("Batch insert %s failed, stop loading. Please check the logs",
                                            mapping.type().string());
                     }
+                } else {
+                    summary.metrics(struct).minusFlighting(batch.size());
                 }
 
                 this.batchSemaphore.release();

Original file line number	Diff line number	Diff line change
`@@ -162,12 +162,13 @@ public void submitBatch(InputStruct struct, ElementMapping mapping,`
`162`	`162`	`mapping.type(), e);`
`163`	`163`	`this.submitInSingle(struct, mapping, batch);`
`164`	`164`	`} else {`
`165`		`- summary.metrics(struct).minusFlighting(batch.size());`
`166`	`165`	`this.context.occurredError();`
`167`	`166`	`this.context.stopLoading();`
`168`	`167`	`Printer.printError("Batch insert %s failed, stop loading. Please check the logs",`
`169`	`168`	`mapping.type().string());`
`170`	`169`	`}`
	`170`	`+ } else {`
	`171`	`+ summary.metrics(struct).minusFlighting(batch.size());`
`171`	`172`	`}`
`172`	`173`
`173`	`174`	`this.batchSemaphore.release();`