You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by di...@apache.org on 2023/06/27 07:02:54 UTC
[doris-flink-connector] branch master updated: Fix issue 149 by appointing a unique uid to each sink operator. (#150)
This is an automated email from the ASF dual-hosted git repository.
diwu 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 542bf26 Fix issue 149 by appointing a unique uid to each sink operator. (#150)
542bf26 is described below
commit 542bf26cdd120e8fbcdb38c827a80f20e5eec2ea
Author: cygnusdark <53...@users.noreply.github.com>
AuthorDate: Tue Jun 27 15:02:49 2023 +0800
Fix issue 149 by appointing a unique uid to each sink operator. (#150)
---
.../src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
index 84d5b57..1699d52 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
@@ -117,7 +117,7 @@ public abstract class DatabaseSync {
DataStream<String> sideOutput = parsedStream.getSideOutput(recordOutputTag);
int sinkParallel = sinkConfig.getInteger(DorisConfigOptions.SINK_PARALLELISM, sideOutput.getParallelism());
- sideOutput.sinkTo(buildDorisSink(table)).setParallelism(sinkParallel).name(table);
+ sideOutput.sinkTo(buildDorisSink(table)).setParallelism(sinkParallel).name(table).uid(table);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org