Skip to content

Commit 27b5484

Browse files
committed
move process footer insude termination if condition
1 parent d672560 commit 27b5484

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataexport/ExportManager.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -112,19 +112,20 @@ public ExportReport startExport(
112112
try {
113113
if (executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)) {
114114
logger.info("All tasks completed");
115+
// Process footer after all tasks are complete
116+
try {
117+
processFooter(exportOptions, tableMetadata, bufferedWriter);
118+
} catch (IOException e) {
119+
logger.error("Error processing footer", e);
120+
}
115121
} else {
116122
logger.error("Timeout occurred while waiting for tasks to complete");
117123
}
118124
} catch (InterruptedException e) {
119125
Thread.currentThread().interrupt();
120126
logger.error("Interrupted while waiting for executor termination", e);
121127
}
122-
// Process footer after all tasks are complete
123-
try {
124-
processFooter(exportOptions, tableMetadata, bufferedWriter);
125-
} catch (IOException e) {
126-
logger.error("Error processing footer", e);
127-
}
128+
128129
// Flush buffered writer
129130
try {
130131
bufferedWriter.flush();

0 commit comments

Comments
 (0)