修复编译错误

entropy-cloud · Nov 16, 2024 · be7e3a2 · be7e3a2
1 parent 27f856c
commit be7e3a2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...p-batch-core/src/main/java/io/nop/batch/core/consumer/ResourceRecordConsumerProvider.java b/...p-batch-core/src/main/java/io/nop/batch/core/consumer/ResourceRecordConsumerProvider.java
@@ -106,7 +106,11 @@ ConsumerState<R> newConsumerState(IBatchTaskContext context) {
             context.onBeforeComplete(() -> {
                 Map<String, Object> trailer = aggregator.complete(null, state.combinedValue);
                 state.output.endWrite(trailer);
-                state.output.flush();
+                try{
+                    state.output.flush();
+                }catch(Exception e){
+                    throw NopException.adapt(e);
+                }
             });
 
             context.onAfterComplete(err -> {