Skip to content

Commit 5b8e63a

Browse files
thongdk8brfrn169
andauthored
Update data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/ImportProcessor.java
Co-authored-by: Toshihiro Suzuki <[email protected]>
1 parent 11ab70b commit 5b8e63a

File tree

1 file changed

+5
-2
lines changed
  • data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor

1 file changed

+5
-2
lines changed

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/ImportProcessor.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -462,8 +462,11 @@ private ImportDataChunkStatus processDataChunkWithoutTransactions(ImportDataChun
462462
boolean allSaved =
463463
result.getTargets().stream()
464464
.allMatch(t -> t.getStatus().equals(ImportTargetResultStatus.SAVED));
465-
if (allSaved) successCount.incrementAndGet();
466-
else failureCount.incrementAndGet();
465+
if (allSaved) {
466+
successCount.incrementAndGet();
467+
} else {
468+
failureCount.incrementAndGet();
469+
}
467470
}
468471
Instant endTime = Instant.now();
469472
int totalDuration = (int) Duration.between(startTime, endTime).toMillis();

0 commit comments

Comments
 (0)