Change the way for getting configuration

apache · Jul 20, 2023 · 112d1ce · 112d1ce
1 parent bdab8d6
commit 112d1ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/main/java/org/apache/seatunnel/core/starter/spark/execution/SinkExecuteProcessor.java b/...src/main/java/org/apache/seatunnel/core/starter/spark/execution/SinkExecuteProcessor.java
@@ -111,7 +111,7 @@ public List<Dataset<Row>> execute(List<Dataset<Row>> upstreamDataStreams)
                                         CommonOptions.PARALLELISM.defaultValue());
             }
             if (sinkConfig.hashPath(CommonOptions.PARTITION_BALANCE.key())) {
-                boolean needBalance = sinkConfig.getBoolean();
+                boolean needBalance = sinkConfig.getBoolean(CommonOptions.PARTITION_BALANCE.key());
                 if (needBalance) {
                     dataset = dataset.repartition(parallelism);
                 }