[Minor] Throws an exception when using bulk_insert and stream mode (a…

…pache#10082) Co-authored-by: leixin1 <leixin1@jd.com>
jonvex · Nov 15, 2023 · 19b3e7f · 19b3e7f
1 parent 055839b
commit 19b3e7f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java
@@ -26,6 +26,7 @@
 import org.apache.hudi.configuration.FlinkOptions;
 import org.apache.hudi.configuration.OptionsInference;
 import org.apache.hudi.configuration.OptionsResolver;
+import org.apache.hudi.exception.HoodieException;
 import org.apache.hudi.sink.utils.Pipelines;
 import org.apache.hudi.util.ChangelogModes;
 import org.apache.hudi.util.DataModificationInfos;
@@ -86,6 +87,10 @@ public SinkRuntimeProvider getSinkRuntimeProvider(Context context) {
 
       // bulk_insert mode
       if (OptionsResolver.isBulkInsertOperation(conf)) {
+        if (!context.isBounded()) {
+          throw new HoodieException(
+              "The bulk insert should be run in batch execution mode.");
+        }
         return Pipelines.bulkInsert(conf, rowType, dataStream);
       }