(flink-cdc) branch master updated: [FLINK-35281][cdc-common] FlinkEnvironmentUtils#addJar add each jar only once (#3301)

2024-07-04 Thread ruanhang1993
This is an automated email from the ASF dual-hosted git repository. ruanhang1993 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-cdc.git The following commit(s) were added to refs/heads/master by this push: new ca1470d5d [FLINK-35281][cdc-common] Fli

(flink) branch master updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2.

2024-07-04 Thread zhuzh
This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 6b08eb15d09 [FLINK-35731][runtime] Fix incorrect p

Re: [I] oracle-connector实时读取只读备库的问题 [flink-cdc]

2024-07-04 Thread via GitHub
xiaofan2022 commented on issue #1315: URL: https://github.com/apache/flink-cdc/issues/1315#issuecomment-2209869175 According to the document: https://www.infoq.cn/article/pgaknsli9xufej9htolt. Modify debizium https://github.com/xiaofan2022/debezium branch: mining_database_1. 9. The usage c

(flink) branch release-1.19 updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF

2024-07-04 Thread lincoln
This is an automated email from the ASF dual-hosted git repository. lincoln pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 2581c26e4f0 [FLINK-35498][table] Fix

(flink) branch release-1.20 updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF

2024-07-04 Thread lincoln
This is an automated email from the ASF dual-hosted git repository. lincoln pushed a commit to branch release-1.20 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.20 by this push: new ce29a69bcbe [FLINK-35498][table] Fix

(flink) branch ngn346 deleted (was 47ce6a97aaf)

2024-07-04 Thread pnowojski
This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a change to branch ngn346 in repository https://gitbox.apache.org/repos/asf/flink.git was 47ce6a97aaf fixup! [NGN-346] Add custom scope variables to operators This change permanently discards the following

(flink) branch master updated: [FLINK-34268] Removing exclusions for FLINK-33676 33805

2024-07-04 Thread martijnvisser
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new cc19159b489 [FLINK-34268] Removing exclusi

Re: [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]

2024-07-04 Thread via GitHub
zbingwen commented on issue #3452: URL: https://github.com/apache/flink-cdc/issues/3452#issuecomment-2208425070 change to below , test is correct. ``` public static GtidSet fixRestoredGtidSet(GtidSet serverGtidSet, GtidSet restoredGtidSet) { Map newSet = new HashMap<>()

Re: [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]

2024-07-04 Thread via GitHub
zbingwen commented on issue #3452: URL: https://github.com/apache/flink-cdc/issues/3452#issuecomment-2208424086 restoredIntervalEnd logic is wrong ``` public static GtidSet fixRestoredGtidSetOld(GtidSet serverGtidSet, GtidSet restoredGtidSet) { Map newSet = new HashMap<>

[I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]

2024-07-04 Thread via GitHub
zbingwen opened a new issue, #3452: URL: https://github.com/apache/flink-cdc/issues/3452 ### Please don't check the box below - [X] I'm aware that bugs and new features should be reported on [Apache Jira](https://issues.apache.org/jira) or Flink mailing list (d...@flink.apache.org)

Re: [I] [Bug] io/debezium/connector/mysql/MySqlConnection$MySqlConnectionConfiguration.class 类重复导致 异常java.lang.NoSuchMethodError [flink-cdc]

2024-07-04 Thread via GitHub
Tangsonghuai commented on issue #3066: URL: https://github.com/apache/flink-cdc/issues/3066#issuecomment-2208332993 debezium的问题请问一下,解决了吗 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif