[jira] [Commented] (FLINK-25537) [JUnit5 Migration] Module: flink-core

2024-05-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844226#comment-17844226 ] Jiabao Sun commented on FLINK-25537: master: ffa3869c48a68c1dd3126fa949adc6953979711f > [JUnit5

[jira] [Closed] (FLINK-35245) Add metrics for flink-connector-tidb-cdc

2024-05-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun closed FLINK-35245. -- Resolution: Implemented Implemented via cdc-master: fa6e7ea51258dcd90f06036196618224156df367 > Add

[jira] [Updated] (FLINK-35245) Add metrics for flink-connector-tidb-cdc

2024-05-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35245: --- Fix Version/s: cdc-3.2.0 > Add metrics for flink-connector-tidb-cdc >

[jira] [Assigned] (FLINK-35245) Add metrics for flink-connector-tidb-cdc

2024-05-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35245: -- Assignee: Xie Yi > Add metrics for flink-connector-tidb-cdc >

[jira] [Closed] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun closed FLINK-35274. -- > Occasional failure issue with Flink CDC Db2 UT > -- > >

[jira] [Resolved] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35274. Resolution: Fixed Fixed via cdc * master: a7cb46f7621568486a069a7ae01a7b86ebb0a801 * release-3.1:

[jira] [Assigned] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35274: -- Assignee: Xin Gong > Occasional failure issue with Flink CDC Db2 UT >

[jira] [Closed] (FLINK-35244) Correct the package for flink-connector-tidb-cdc test

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun closed FLINK-35244. -- > Correct the package for flink-connector-tidb-cdc test >

[jira] [Resolved] (FLINK-35244) Correct the package for flink-connector-tidb-cdc test

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35244. Fix Version/s: cdc-3.2.0 Resolution: Fixed Resolved via cdc-master:

[jira] [Updated] (FLINK-35244) Correct the package for flink-connector-tidb-cdc test

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35244: --- Summary: Correct the package for flink-connector-tidb-cdc test (was: Move package for

[jira] [Resolved] (FLINK-32843) [JUnit5 Migration] The jobmaster package of flink-runtime module

2024-05-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-32843. Fix Version/s: 1.20.0 Resolution: Fixed Resolved via master:

[jira] [Assigned] (FLINK-35244) Move package for flink-connector-tidb-cdc test

2024-04-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35244: -- Assignee: Xie Yi > Move package for flink-connector-tidb-cdc test >

[jira] [Resolved] (FLINK-35235) Fix missing dependencies in the uber jar

2024-04-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35235. Assignee: LvYanquan Resolution: Fixed Resolved via * cdc master:

[jira] [Assigned] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation

2024-04-17 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34738: -- Assignee: Vincent Woo > "Deployment - YARN" Page for Flink CDC Chinese Documentation >

[jira] [Commented] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

2024-04-17 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838077#comment-17838077 ] Jiabao Sun commented on FLINK-35139: mongodb main: 660ffe4f33f3ce60da139159741644f48295652d >

[jira] [Resolved] (FLINK-35079) MongoConnector failed to resume token when current collection removed

2024-04-16 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35079. Fix Version/s: cdc-3.1.0 Resolution: Fixed resolved via cdc master:

[jira] [Commented] (FLINK-35127) CDC ValuesDataSourceITCase crashed due to OutOfMemoryError

2024-04-16 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837929#comment-17837929 ] Jiabao Sun commented on FLINK-35127: Hi [~kunni], Could you help take a look? > CDC

[jira] [Created] (FLINK-35127) CDC ValuesDataSourceITCase crashed due to OutOfMemoryError

2024-04-16 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-35127: -- Summary: CDC ValuesDataSourceITCase crashed due to OutOfMemoryError Key: FLINK-35127 URL: https://issues.apache.org/jira/browse/FLINK-35127 Project: Flink Issue

[jira] [Commented] (FLINK-25537) [JUnit5 Migration] Module: flink-core

2024-04-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837471#comment-17837471 ] Jiabao Sun commented on FLINK-25537: master: 138f1f9d17b7a58b092ee7d9fc4c20d968a7b33b > [JUnit5

[jira] [Closed] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Mongodb connector

2024-04-09 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun closed FLINK-35010. -- > Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink > Mongodb connector >

[jira] [Resolved] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Mongodb connector

2024-04-09 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35010. Fix Version/s: mongodb-1.2.0 Resolution: Fixed Fixed via mongodb-connector main:

[jira] [Updated] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Mongodb connector

2024-04-09 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35010: --- Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Mongodb connector

[jira] [Commented] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-08 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835156#comment-17835156 ] Jiabao Sun commented on FLINK-35008: I agree with Sergey's opinion. In version 1.26.0, the

[jira] [Commented] (FLINK-34921) SystemProcessingTimeServiceTest fails due to missing output

2024-04-08 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834864#comment-17834864 ] Jiabao Sun commented on FLINK-34921: Maybe we shouldn't use ScheduledFuture.get() to check the

[jira] [Commented] (FLINK-34955) Upgrade commons-compress to 1.26.0

2024-04-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834779#comment-17834779 ] Jiabao Sun commented on FLINK-34955: I have rechecked the dependency of `commons-codec` in

[jira] [Commented] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector

2024-04-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834778#comment-17834778 ] Jiabao Sun commented on FLINK-35010: I have rechecked the dependency of `commons-codec` in

[jira] [Commented] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834777#comment-17834777 ] Jiabao Sun commented on FLINK-35008: I have rechecked the dependency of `commons-codec` in

[jira] [Assigned] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector

2024-04-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35010: -- Assignee: Zhongqiang Gong > Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0

[jira] [Commented] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector

2024-04-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834607#comment-17834607 ] Jiabao Sun commented on FLINK-35010: I think we should bump commons-compress version to 1.26.1 due

[jira] [Commented] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834606#comment-17834606 ] Jiabao Sun commented on FLINK-35008: Due to an incorrect dependency on the Charsets class in the

[jira] [Commented] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834604#comment-17834604 ] Jiabao Sun commented on FLINK-35008: Hi [~martijnvisser], maybe we should bump the commons-compress

[jira] [Commented] (FLINK-34405) RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort2 fails due to an interruption of the RightOuterJoinDriver#prepare method

2024-04-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834591#comment-17834591 ] Jiabao Sun commented on FLINK-34405: taskRunner Thread: testDriver() ->

[jira] [Resolved] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector

2024-04-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35011. Resolution: Fixed Fixed via master: 3590c2d86f4186771ffcd64712f756d31306eb88 > The change in

[jira] [Created] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector

2024-04-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-35011: -- Summary: The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector Key: FLINK-35011 URL: https://issues.apache.org/jira/browse/FLINK-35011

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-04-04 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833989#comment-17833989 ] Jiabao Sun commented on FLINK-25544: Thanks [~martijnvisser] for reporting this problem. The

[jira] [Resolved] (FLINK-34948) CDC RowType can not convert to flink row type

2024-03-31 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34948. Assignee: Qishang Zhong Resolution: Fixed Fixed via cdc master: 

[jira] [Updated] (FLINK-34948) CDC RowType can not convert to flink row type

2024-03-31 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34948: --- Priority: Critical (was: Minor) > CDC RowType can not convert to flink row type >

[jira] [Updated] (FLINK-34958) Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector

2024-03-28 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34958: --- Affects Version/s: mongodb-1.1.0 (was: mongodb-1.0.2) > Add support

[jira] [Updated] (FLINK-34958) Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector

2024-03-28 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34958: --- Fix Version/s: mongodb-1.2.0 (was: mongodb-1.1.0) > Add support Flink

[jira] [Updated] (FLINK-34958) Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector

2024-03-28 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34958: --- Affects Version/s: mongodb-1.0.2 > Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent

[jira] [Resolved] (FLINK-34958) Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector

2024-03-28 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34958. Fix Version/s: mongodb-1.1.0 Resolution: Implemented Implemented via (mongodb:main)

[jira] [Assigned] (FLINK-34753) Update outdated MongoDB CDC FAQ in doc

2024-03-28 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34753: -- Assignee: Xiao Huang > Update outdated MongoDB CDC FAQ in doc >

[jira] [Resolved] (FLINK-34753) Update outdated MongoDB CDC FAQ in doc

2024-03-28 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34753. Resolution: Fixed Resolved by flink-cdc master: 927a0ec4743ac70c5d4edb811da7ffce09658e8b >

[jira] [Resolved] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure

2024-03-18 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34719. Fix Version/s: 1.12.0 Resolution: Fixed > StreamRecordTest#testWithTimestamp fails on

[jira] [Commented] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure

2024-03-18 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828129#comment-17828129 ] Jiabao Sun commented on FLINK-34719: Fixed via master: 8ec5e7e830b5bda30ead3638a1faa3567d80bb7b >

[jira] [Assigned] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure

2024-03-18 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34719: -- Assignee: Jiabao Sun > StreamRecordTest#testWithTimestamp fails on Azure >

[jira] [Commented] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure

2024-03-18 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828012#comment-17828012 ] Jiabao Sun commented on FLINK-34719: Thanks [~rskraba] for reporting this. I'm looking into this

[jira] [Commented] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827462#comment-17827462 ] Jiabao Sun commented on FLINK-34585: Thanks [~kunni] for volunteering. Assigned to you. > [JUnit5

[jira] [Assigned] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34585: -- Assignee: LvYanquan > [JUnit5 Migration] Module: Flink CDC >

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827460#comment-17827460 ] Jiabao Sun commented on FLINK-25544: master: 62f44e0118539c1ed0dedf47099326f97c9d0427 > [JUnit5

[jira] [Updated] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-25544: --- Release Note: (was: master: 62f44e0118539c1ed0dedf47099326f97c9d0427) > [JUnit5 Migration]

[jira] [Resolved] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-25544. Fix Version/s: 1.20.0 Release Note: master: 62f44e0118539c1ed0dedf47099326f97c9d0427

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824476#comment-17824476 ] Jiabao Sun commented on FLINK-25544: master: 395928901cb99c019d8885d1c39839c33e5ed587

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824373#comment-17824373 ] Jiabao Sun commented on FLINK-25544: master: 6f7b24817a81995e90cfc2cd77efadb41be8cddc > [JUnit5

[jira] [Resolved] (FLINK-34183) Add NOTICE files for Flink CDC project

2024-03-06 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34183. Fix Version/s: cdc-3.1.0 Resolution: Implemented Implement via flink-cdc master:

[jira] [Resolved] (FLINK-34577) Add IssueNavigationLink for IDEA git log

2024-03-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34577. Fix Version/s: cdc-3.1.0 Resolution: Implemented Implemented via flink-cdc (master):

[jira] [Assigned] (FLINK-34577) Add IssueNavigationLink for IDEA git log

2024-03-05 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34577: -- Assignee: Zhongqiang Gong > Add IssueNavigationLink for IDEA git log >

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-03 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823018#comment-17823018 ] Jiabao Sun commented on FLINK-25544: Hi [~Thesharing]. I assigned this ticket to myself as this

[jira] [Assigned] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-03 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-25544: -- Assignee: Jiabao Sun (was: Zhilong Hong) > [JUnit5 Migration] Module: flink-streaming-java

[jira] [Resolved] (FLINK-34492) fix scala style comment link when migrate scala to java

2024-03-01 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34492. Resolution: Fixed master: 46cbf22147d783fb68f77fad95161dc5ef036c96 > fix scala style comment

[jira] [Assigned] (FLINK-34492) fix scala style comment link when migrate scala to java

2024-03-01 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34492: -- Assignee: Jacky Lau > fix scala style comment link when migrate scala to java >

[jira] [Reopened] (FLINK-25537) [JUnit5 Migration] Module: flink-core

2024-02-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reopened FLINK-25537: I noticed that there are remaining test in other packages. Hi [~Aiden Gong], will you continue to

[jira] [Resolved] (FLINK-25537) [JUnit5 Migration] Module: flink-core

2024-02-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-25537. Fix Version/s: 1.20.0 Resolution: Fixed > [JUnit5 Migration] Module: flink-core >

[jira] [Commented] (FLINK-25537) [JUnit5 Migration] Module: flink-core

2024-02-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820667#comment-17820667 ] Jiabao Sun commented on FLINK-25537: master: 922cc2ad52203e4c474f3837fcc9a219dd293fa5 > [JUnit5

[jira] [Resolved] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17

2024-02-19 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34461. Fix Version/s: mongodb-1.1.0 Resolution: Fixed > MongoDB weekly builds fail with time out

[jira] [Commented] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17

2024-02-19 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818527#comment-17818527 ] Jiabao Sun commented on FLINK-34461: The reason for this issue is that the v1.0 branch is missing

[jira] [Assigned] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17

2024-02-19 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34461: -- Assignee: Jiabao Sun > MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17 >

[jira] [Commented] (FLINK-34214) FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

2024-02-11 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816377#comment-17816377 ] Jiabao Sun commented on FLINK-34214: Hi [~stayrascal]. When pushing to the database without

[jira] [Created] (FLINK-34337) Sink.InitContextWrapper should implement metadataConsumer method

2024-02-01 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-34337: -- Summary: Sink.InitContextWrapper should implement metadataConsumer method Key: FLINK-34337 URL: https://issues.apache.org/jira/browse/FLINK-34337 Project: Flink

[jira] [Commented] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-30 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812312#comment-17812312 ] Jiabao Sun commented on FLINK-34259: The PR was reopened, PTAL. > flink-connector-jdbc fails to

[jira] [Commented] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-30 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812299#comment-17812299 ] Jiabao Sun commented on FLINK-34259: [~martijnvisser] But I still have a question. In the previous

[jira] [Commented] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-30 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812293#comment-17812293 ] Jiabao Sun commented on FLINK-34259: Thanks [~martijnvisser] , I will close the PR for the JDBC

[jira] [Comment Edited] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-30 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812291#comment-17812291 ] Jiabao Sun edited comment on FLINK-34259 at 1/30/24 12:45 PM: --

[jira] [Commented] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-30 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812291#comment-17812291 ] Jiabao Sun commented on FLINK-34259: [~martijnvisser] It seems introduced by

[jira] [Commented] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-01-29 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811941#comment-17811941 ] Jiabao Sun commented on FLINK-34260: Sorry [~dannycranmer], I just noticed this comment. I made some

[jira] [Commented] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-01-29 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811807#comment-17811807 ] Jiabao Sun commented on FLINK-34260: Hi [~martijnvisser], can I take this ticket? > Update

[jira] [Comment Edited] (FLINK-34087) [JUnit5 Migration] Module: flink-dist

2024-01-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811158#comment-17811158 ] Jiabao Sun edited comment on FLINK-34087 at 1/26/24 8:10 AM: - Resolved via

[jira] [Resolved] (FLINK-34087) [JUnit5 Migration] Module: flink-dist

2024-01-26 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34087. Resolution: Duplicate Resolved by FLIK-33577 > [JUnit5 Migration] Module: flink-dist >

[jira] [Commented] (FLINK-34113) Update flink-connector-elasticsearch to be compatible with updated SinkV2 interfaces

2024-01-25 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811151#comment-17811151 ] Jiabao Sun commented on FLINK-34113: [~martijnvisser] We can use TestSinkInitContext instead of

[jira] [Created] (FLINK-34216) Support fine-grained configuration to control filter push down for MongoDB Connector

2024-01-23 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-34216: -- Summary: Support fine-grained configuration to control filter push down for MongoDB Connector Key: FLINK-34216 URL: https://issues.apache.org/jira/browse/FLINK-34216

[jira] [Created] (FLINK-34215) Support fine-grained configuration to control filter push down for JDBC Connector

2024-01-23 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-34215: -- Summary: Support fine-grained configuration to control filter push down for JDBC Connector Key: FLINK-34215 URL: https://issues.apache.org/jira/browse/FLINK-34215

[jira] [Created] (FLINK-34214) FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

2024-01-23 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-34214: -- Summary: FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources Key: FLINK-34214 URL: https://issues.apache.org/jira/browse/FLINK-34214

[jira] [Commented] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1

2024-01-22 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809489#comment-17809489 ] Jiabao Sun commented on FLINK-31724:

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-01-19 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808635#comment-17808635 ] Jiabao Sun commented on FLINK-34156: Thanks [~Sergey Nuyanzin]. If there is a need for assistance,

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-01-18 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808425#comment-17808425 ] Jiabao Sun commented on FLINK-34156: Hi [~Sergey Nuyanzin], can I help with this task? > Move Flink

[jira] [Commented] (FLINK-33717) Cleanup the usage of deprecated StreamTableEnvironment#fromDataStream

2024-01-17 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808053#comment-17808053 ] Jiabao Sun commented on FLINK-33717: Hi [~jackylau], are you still working on this? Could I help

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34076: --- Attachment: screenshot-4.png > flink-connector-base missing fails kinesis table sink to create >

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806783#comment-17806783 ] Jiabao Sun commented on FLINK-34076: Hey [~dannycranmer], it's in dependencies. !screenshot-4.png!

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806747#comment-17806747 ] Jiabao Sun commented on FLINK-34076: flink-connector-base has already been included as a parent

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806723#comment-17806723 ] Jiabao Sun commented on FLINK-34076: The purpose of "Stop bundling connector-base in externalized

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34076: --- Attachment: screenshot-3.png > flink-connector-base missing fails kinesis table sink to create >

[jira] [Commented] (FLINK-33816) SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain failed due async checkpoint triggering not being completed

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806705#comment-17806705 ] Jiabao Sun commented on FLINK-33816: Resuming the first breakpoint will unblock the main thread and

[jira] [Created] (FLINK-34087) [JUnit5 Migration] Module: flink-dist

2024-01-15 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-34087: -- Summary: [JUnit5 Migration] Module: flink-dist Key: FLINK-34087 URL: https://issues.apache.org/jira/browse/FLINK-34087 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806677#comment-17806677 ] Jiabao Sun commented on FLINK-34076: Hi [~khanhvu], The flink-connector-base is already included in

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34076: --- Attachment: screenshot-2.png > flink-connector-base missing fails kinesis table sink to create >

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806605#comment-17806605 ] Jiabao Sun commented on FLINK-34076: Hi [~khanhvu], do you add dependencies with "provided" scope to

[jira] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076 ] Jiabao Sun deleted comment on FLINK-34076: was (Author: jiabao.sun): Hi [~khanhvu], do you add dependencies with "provided" scope to classpath? !screenshot-1.png! > flink-connector-base

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34076: --- Attachment: screenshot-1.png > flink-connector-base missing fails kinesis table sink to create >

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806603#comment-17806603 ] Jiabao Sun commented on FLINK-34076: Hi [~khanhvu], do you add dependencies with "provided" scope to

[jira] [Commented] (FLINK-33816) SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain failed due async checkpoint triggering not being completed

2024-01-01 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801662#comment-17801662 ] Jiabao Sun commented on FLINK-33816: !screenshot-1.png! Add thread suspended breakpoints at

  1   2   3   >