[jira] [Resolved] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-37255. Resolution: Fixed > Unsupported options: scan.partition.record-size >

[jira] [Comment Edited] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923982#comment-17923982 ] Jiabao Sun edited comment on FLINK-37255 at 2/5/25 11:11 AM: -

[jira] [Commented] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923982#comment-17923982 ] Jiabao Sun commented on FLINK-37255: Fixed via mongodb repo main: 123334b8a70e5b3cc

[jira] [Commented] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923955#comment-17923955 ] Jiabao Sun commented on FLINK-37255: Thanks [~xiqian_yu], assigned to you. > Unsupp

[jira] [Assigned] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-37255: -- Assignee: yux (was: Jiabao Sun) > Unsupported options: scan.partition.record-size >

[jira] [Updated] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-37255: --- Description: The new configuration option scan.partition.record-size was introduced by FLINK-36075,

[jira] [Updated] (FLINK-37255) Unsupported options: scan.partition.record-size

[ https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-37255: --- Priority: Blocker (was: Major) > Unsupported options: scan.partition.record-size >

[jira] [Created] (FLINK-37255) Unsupported options: scan.partition.record-size

Jiabao Sun created FLINK-37255: -- Summary: Unsupported options: scan.partition.record-size Key: FLINK-37255 URL: https://issues.apache.org/jira/browse/FLINK-37255 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37197) Release flink-connector-mongodb v2.0.0 for Flink 1.20

Jiabao Sun created FLINK-37197: -- Summary: Release flink-connector-mongodb v2.0.0 for Flink 1.20 Key: FLINK-37197 URL: https://issues.apache.org/jira/browse/FLINK-37197 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-36074) Support insert overwrite semantics for mongodb table sink

[ https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-36074. Resolution: Fixed Implemented via flink-connector-mongodb main: 0e31aa8890e4514c84e1f1d11e4e0d287

[jira] [Resolved] (FLINK-36952) Fix MongoDB connector Chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-36952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-36952. Fix Version/s: cdc-3.3.0 Resolution: Fixed Fixed via cdc master: 4f881f82d4623f07f8175dc4f1

[jira] [Assigned] (FLINK-36952) Fix MongoDB connector Chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-36952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-36952: -- Assignee: Thorne > Fix MongoDB connector Chinese documentation >

[jira] [Resolved] (FLINK-36075) Add paginate partition strategy for mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-36075. Resolution: Implemented Implemented via connector-mongodb main: fd177d71b705da3e2749077d1b860eb3d1

[jira] [Created] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21

Jiabao Sun created FLINK-36738: -- Summary: Weekly CI for MongoDB connector fails on jdk21 Key: FLINK-36738 URL: https://issues.apache.org/jira/browse/FLINK-36738 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-36075) Add paginate partition strategy for mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-36075: -- Assignee: yux (was: Jiabao Sun) > Add paginate partition strategy for mongodb connector > --

[jira] [Commented] (FLINK-36075) Add paginate partition strategy for mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889912#comment-17889912 ] Jiabao Sun commented on FLINK-36075: Hi [~xiqian_yu], would you like to take this ti

[jira] [Commented] (FLINK-36228) MongoDB sink should be asynchronous

[ https://issues.apache.org/jira/browse/FLINK-36228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880238#comment-17880238 ] Jiabao Sun commented on FLINK-36228: Hi [~jjf0], how many documents can be written p

[jira] [Comment Edited] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements

[ https://issues.apache.org/jira/browse/FLINK-36051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878674#comment-17878674 ] Jiabao Sun edited comment on FLINK-36051 at 9/3/24 1:26 AM:

[jira] [Resolved] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements

[ https://issues.apache.org/jira/browse/FLINK-36051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-36051. Fix Version/s: jdbc-3.3.0 Assignee: Sergei Morozov Resolution: Fixed fixed via fli

[jira] [Comment Edited] (FLINK-36097) Add timeseries support for SampleSplitter

[ https://issues.apache.org/jira/browse/FLINK-36097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875043#comment-17875043 ] Jiabao Sun edited comment on FLINK-36097 at 8/20/24 4:15 AM: -

[jira] [Commented] (FLINK-36097) Add timeseries support for SampleSplitter

[ https://issues.apache.org/jira/browse/FLINK-36097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875043#comment-17875043 ] Jiabao Sun commented on FLINK-36097: The avgObjSize is also returned from the `$coll

[jira] [Updated] (FLINK-36097) Add timeseries support for SampleSplitter

[ https://issues.apache.org/jira/browse/FLINK-36097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-36097: --- Priority: Minor (was: Major) > Add timeseries support for SampleSplitter >

[jira] [Updated] (FLINK-36097) Add timeseries support for SampleSplitter

[ https://issues.apache.org/jira/browse/FLINK-36097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-36097: --- Fix Version/s: (was: mongodb-1.3.0) > Add timeseries support for SampleSplitter > --

[jira] [Created] (FLINK-36097) Add timeseries support for SampleSplitter

Jiabao Sun created FLINK-36097: -- Summary: Add timeseries support for SampleSplitter Key: FLINK-36097 URL: https://issues.apache.org/jira/browse/FLINK-36097 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-36053) Support multi-version integration test in mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-36053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-36053. Resolution: Implemented implemented by main: 97ec9b4314cdae92d050c112cef2112aed421e4e 4b8f5f93c2c1

[jira] [Created] (FLINK-36075) Add paginate partition strategy for mongodb connector

Jiabao Sun created FLINK-36075: -- Summary: Add paginate partition strategy for mongodb connector Key: FLINK-36075 URL: https://issues.apache.org/jira/browse/FLINK-36075 Project: Flink Issue Type:

[jira] [Updated] (FLINK-36074) Support insert overwrite semantics for mongodb table sink

[ https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-36074: --- Summary: Support insert overwrite semantics for mongodb table sink (was: Support insert overwrite s

[jira] [Updated] (FLINK-36074) Support insert overwrite semantics for mongodb table sink.

[ https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-36074: --- Description: Support insert overwrite semantics for mongodb table sink. (was: Supprt insert overwri

[jira] [Updated] (FLINK-36074) Support insert overwrite semantics for mongodb table sink.

[ https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-36074: --- Summary: Support insert overwrite semantics for mongodb table sink. (was: Supprt insert overwrite s

[jira] [Created] (FLINK-36074) Supprt insert overwrite semantics for mongodb table sink.

Jiabao Sun created FLINK-36074: -- Summary: Supprt insert overwrite semantics for mongodb table sink. Key: FLINK-36074 URL: https://issues.apache.org/jira/browse/FLINK-36074 Project: Flink Issue T

[jira] [Created] (FLINK-36053) Support multi-version integration test in mongodb connector

Jiabao Sun created FLINK-36053: -- Summary: Support multi-version integration test in mongodb connector Key: FLINK-36053 URL: https://issues.apache.org/jira/browse/FLINK-36053 Project: Flink Issu

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

[ https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34214. Assignee: Jiabao Sun (was: jiabao.sun) Resolution: Implemented jdbc main(3.3.0) via : b5980

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

[ https://issues.apache.org/jira/browse/FLINK-34216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34216. Assignee: Jiabao Sun Resolution: Implemented merged into main: 424d57a54c69d9d0e0fde4219e46b

[jira] [Assigned] (FLINK-35980) Add transform test coverage in Integrated / E2e tests

[ https://issues.apache.org/jira/browse/FLINK-35980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35980: -- Assignee: yux > Add transform test coverage in Integrated / E2e tests > -

[jira] [Closed] (FLINK-35975) MongoFilterPushDownVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun closed FLINK-35975. -- > MongoFilterPushDownVisitorTest fails > > > Key: FLI

[jira] [Resolved] (FLINK-35975) MongoFilterPushDownVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35975. Resolution: Fixed main: 98ada669bef8bf43d7f33dce73d0a7a99ea6fbbe > MongoFilterPushDownVisitorTest

[jira] [Created] (FLINK-35975) MongoFilterPushDownVisitorTest fails

Jiabao Sun created FLINK-35975: -- Summary: MongoFilterPushDownVisitorTest fails Key: FLINK-35975 URL: https://issues.apache.org/jira/browse/FLINK-35975 Project: Flink Issue Type: Bug Co

[jira] [Commented] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

[ https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870454#comment-17870454 ] Jiabao Sun commented on FLINK-35968: Thanks [~loserwang1024] for the volunteering, a

[jira] [Assigned] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

[ https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35968: -- Assignee: Hongshun Wang > Remove flink-cdc-runtime depedency from connectors > --

[jira] [Assigned] (FLINK-35889) mongo cdc restore from expired resume token and job status still running but expect failed

[ https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35889: -- Assignee: yux > mongo cdc restore from expired resume token and job status still running but

[jira] [Comment Edited] (FLINK-35889) mongo cdc restore from expired resume token and job status still running but expect failed

[ https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868311#comment-17868311 ] Jiabao Sun edited comment on FLINK-35889 at 7/24/24 9:36 AM: -

[jira] [Commented] (FLINK-35889) mongo cdc restore from expired resume token and job status still running but expect failed

[ https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868311#comment-17868311 ] Jiabao Sun commented on FLINK-35889: Hi @yux, could you help investigate this? > mo

[jira] [Resolved] (FLINK-35623) Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0

[ https://issues.apache.org/jira/browse/FLINK-35623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35623. Resolution: Implemented main: a7551187d904ed819db085fc36c2cf735913ed5e > Bump mongo-driver versio

[jira] [Assigned] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+

[ https://issues.apache.org/jira/browse/FLINK-35868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35868: -- Assignee: yux > Bump Mongo driver version to support Mongo 7.0+ > ---

[jira] [Resolved] (FLINK-35616) Support upsert into sharded collections for MongoRowDataSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35616. Fix Version/s: mongodb-1.3.0 Resolution: Implemented mongodb-connector main: a2f1083c2b0020

[jira] [Commented] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector.

[ https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866208#comment-17866208 ] Jiabao Sun commented on FLINK-35849: Thanks [~loserwang1024], assigned to you. > [f

[jira] [Assigned] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector.

[ https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35849: -- Assignee: Hongshun Wang > [flink-cdc] Use expose_snapshot to read snapshot splits of postgres

[jira] [Updated] (FLINK-35616) Support upsert into sharded collections for MongoRowDataSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35616: --- Summary: Support upsert into sharded collections for MongoRowDataSerializationSchema (was: Support

[jira] [Created] (FLINK-35623) Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0

Jiabao Sun created FLINK-35623: -- Summary: Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0 Key: FLINK-35623 URL: https://issues.apache.org/jira/browse/FLINK-35623 Project: Flink

[jira] [Created] (FLINK-35618) Flink CDC add MongoDB pipeline data sink connector

Jiabao Sun created FLINK-35618: -- Summary: Flink CDC add MongoDB pipeline data sink connector Key: FLINK-35618 URL: https://issues.apache.org/jira/browse/FLINK-35618 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-35616) Support upsert into sharded collections

Jiabao Sun created FLINK-35616: -- Summary: Support upsert into sharded collections Key: FLINK-35616 URL: https://issues.apache.org/jira/browse/FLINK-35616 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-35121) CDC pipeline connector should verify requiredOptions and optionalOptions

[ https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35121. Assignee: yux Resolution: Implemented Implemented by flink-cdc master: 2bd2e4ce24ec0cc6a1112

[jira] [Updated] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35545: --- Affects Version/s: cdc-3.1.0 > Miss 3.1.0 version in snapshot flink-cdc doc version list > -

[jira] [Updated] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35545: --- Summary: Miss 3.1.0 version in snapshot flink-cdc doc version list (was: Miss 3.0.1 version in snap

[jira] [Assigned] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35545: -- Assignee: Zhongqiang Gong > Miss 3.1.0 version in snapshot flink-cdc doc version list > -

[jira] [Commented] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

[ https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852690#comment-17852690 ] Jiabao Sun commented on FLINK-35149: flink-cdc release-3.1: fa9fb0b1c49848e77c211a59

[jira] [Updated] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

[ https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35149: --- Release Note: (was: cdc release-3.1: fa9fb0b1c49848e77c211a5913d7f28c33e04ff0) > Fix DataSinkTran

[jira] [Resolved] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

[ https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35149. Release Note: cdc release-3.1: fa9fb0b1c49848e77c211a5913d7f28c33e04ff0 Resolution: Fixed >

[jira] [Resolved] (FLINK-35527) Polish quickstart guide & clean stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-35527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-35527. Fix Version/s: cdc-3.2.0 Resolution: Fixed cdc master: b1e157468a703e53c3217940182f5f1a021c

[jira] [Updated] (FLINK-35527) Polish quickstart guide & clean stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-35527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35527: --- Fix Version/s: (was: cdc-3.2.0) > Polish quickstart guide & clean stale links in docs >

[jira] [Updated] (FLINK-35527) Polish quickstart guide & clean stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-35527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35527: --- Fix Version/s: cdc-3.1.1 > Polish quickstart guide & clean stale links in docs > ---

[jira] [Assigned] (FLINK-35527) Polish quickstart guide & clean stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-35527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35527: -- Assignee: yux > Polish quickstart guide & clean stale links in docs > ---

[jira] [Commented] (FLINK-35295) Improve jdbc connection pool initialization failure message

[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850903#comment-17850903 ] Jiabao Sun commented on FLINK-35295: release-3.1: e18e7a2523ac1ea59471e5714eb60f544e

[jira] [Updated] (FLINK-35295) Improve jdbc connection pool initialization failure message

[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-35295: --- Fix Version/s: cdc-3.1.1 > Improve jdbc connection pool initialization failure message > ---

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

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844226#comment-17844226 ] Jiabao Sun commented on FLINK-25537: master: ffa3869c48a68c1dd3126fa949adc6953979711

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

[ 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 me

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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: 002b16ed4e155b01374040f

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

[ 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 flink-connec

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

[ 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: beb0b167bdcf95f27be87a214a69a1

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

[ 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

[ 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: ec643c9dd7365261f3cee620d4

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838077#comment-17838077 ] Jiabao Sun commented on FLINK-35139: mongodb main: 660ffe4f33f3ce60da139159741644f48

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

[ 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: 0562e35da75fb2c8e512d43

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

[ https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837471#comment-17837471 ] Jiabao Sun commented on FLINK-25537: master: 138f1f9d17b7a58b092ee7d9fc4c20d968a7b33

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

[ 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

[ 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: ee1146dadf

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835156#comment-17835156 ] Jiabao Sun commented on FLINK-35008: I agree with Sergey's opinion. In version 1.2

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834779#comment-17834779 ] Jiabao Sun commented on FLINK-34955: I have rechecked the dependency of `commons-cod

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

[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834778#comment-17834778 ] Jiabao Sun commented on FLINK-35010: I have rechecked the dependency of `commons-cod

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

[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834777#comment-17834777 ] Jiabao Sun commented on FLINK-35008: I have rechecked the dependency of `commons-cod

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

[ 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 fo

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

[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834607#comment-17834607 ] Jiabao Sun commented on FLINK-35010: I think we should bump commons-compress version

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

[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834606#comment-17834606 ] Jiabao Sun commented on FLINK-35008: Due to an incorrect dependency on the Charsets

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

[ https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834604#comment-17834604 ] Jiabao Sun commented on FLINK-35008: Hi [~martijnvisser], maybe we should bump the c

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

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

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

[ 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 visi

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

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

[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833989#comment-17833989 ] Jiabao Sun commented on FLINK-25544: Thanks [~martijnvisser] for reporting this prob

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

[ 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: d099603ef15d9a1ed7ec33718db7

  1   2   3   4   >