[doris-flink-connector] branch master updated: fix sink parallelism (#77)

[jiafengzheng]

This is an automated email from the ASF dual-hosted git repository.

jiafengzheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 6693e99  fix sink parallelism (#77)
6693e99 is described below

commit 6693e99f9a1e6b650b41d764bc3eca474aad812d
Author: wudi <676366...@qq.com>
AuthorDate: Mon Oct 31 09:47:13 2022 +0800

    fix sink parallelism (#77)
    
    fix sink parallelism
---
 .../java/org/apache/doris/flink/table/DorisDynamicTableFactory.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
index 521724b..df7b867 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
@@ -216,7 +216,7 @@ public final class DorisDynamicTableFactory implements 
DynamicTableSourceFactory
         // validate all options
         helper.validateExcept(STREAM_LOAD_PROP_PREFIX);
         // sink parallelism
-        final Integer parallelism = 
context.getConfiguration().getOptional(SINK_PARALLELISM).orElse(null);
+        final Integer parallelism = helper.getOptions().get(SINK_PARALLELISM);
 
         Properties streamLoadProp = 
getStreamLoadProp(context.getCatalogTable().getOptions());
         TableSchema physicalSchema =


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org