You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ji...@apache.org on 2022/10/31 01:47:18 UTC
[doris-flink-connector] branch master updated: fix sink parallelism (#77)
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 <67...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org