You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Edward Zhang (Jira)" <ji...@apache.org> on 2025/10/27 14:19:00 UTC
[jira] [Commented] (FLINK-35913) The issue of using StreamExecutioneEnvironment to execute multiple jobs in a program on Flink CDC
[ https://issues.apache.org/jira/browse/FLINK-35913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18033256#comment-18033256 ]
Edward Zhang commented on FLINK-35913:
--------------------------------------
This is issue should be closed. Duplicate to [FLINK-35951|https://issues.apache.org/jira/browse/FLINK-35951] providing a more detail description of the same problem.
> The issue of using StreamExecutioneEnvironment to execute multiple jobs in a program on Flink CDC
> -------------------------------------------------------------------------------------------------
>
> Key: FLINK-35913
> URL: https://issues.apache.org/jira/browse/FLINK-35913
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Reporter: huxx
> Priority: Major
> Attachments: image-2024-07-29-12-23-55-766.png, image-2024-07-29-12-25-19-146.png
>
>
> I integrated Flink CDC with Springboot and attempted to listen to multiple data sources using a single program, as described above. I used StreamExecutioneEnvironment to execute multiple jobs and built different data sources. However, when I tried the second task, I received multiple warnings
> like this
> WARN 21828 --- [rce-coordinator] io.debezium.metrics.Metrics : Unable to register metrics as an old set with the same name exists, retrying in PT5S (attempt 1 out of 12)
> The final result was that my second job was not executed.
> Did you say that my StreamExecutionEnvironment registered duplicate parameters? I don't know how to solve this problem? Can't a single StreamExecutioneEnvironment execute multiple jobs? Thank you for your reply
> !image-2024-07-29-12-23-55-766.png!
> !image-2024-07-29-12-25-19-146.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)