[jira] [Updated] (FLINK-35415) CDC Fails to create sink with Flink 1.19

2024-06-07 Thread Leonard Xu (Jira)


 [ 
https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Leonard Xu updated FLINK-35415:
---
Fix Version/s: cdc-3.1.1

> CDC Fails to create sink with Flink 1.19
> 
>
> Key: FLINK-35415
> URL: https://issues.apache.org/jira/browse/FLINK-35415
> Project: Flink
>  Issue Type: Bug
>  Components: Flink CDC
>Affects Versions: cdc-3.1.0
>Reporter: yux
>Assignee: yux
>Priority: Major
>  Labels: pull-request-available
> Fix For: cdc-3.2.0, cdc-3.1.1
>
>
> Currently, Flink CDC doesn't work with Flink 1.19 with the following 
> exception:
> Exception in thread "main" java.lang.NoSuchMethodError: 'void 
> org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink,
>  boolean, boolean)'
> The reason is Flink CDC uses Flink @Internal API and it was changed in 1.19 
> update.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)


[jira] [Updated] (FLINK-35415) CDC Fails to create sink with Flink 1.19

2024-05-22 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-35415:
---
Labels: pull-request-available  (was: )

> CDC Fails to create sink with Flink 1.19
> 
>
> Key: FLINK-35415
> URL: https://issues.apache.org/jira/browse/FLINK-35415
> Project: Flink
>  Issue Type: Bug
>  Components: Flink CDC
>Affects Versions: cdc-3.1.0
>Reporter: yux
>Assignee: yux
>Priority: Major
>  Labels: pull-request-available
> Fix For: cdc-3.2.0
>
>
> Currently, Flink CDC doesn't work with Flink 1.19 with the following 
> exception:
> Exception in thread "main" java.lang.NoSuchMethodError: 'void 
> org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink,
>  boolean, boolean)'
> The reason is Flink CDC uses Flink @Internal API and it was changed in 1.19 
> update.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)