[jira] [Created] (FLINK-36808) UNION ALL after lookup join produces unexpected results

Qingsheng Ren created FLINK-36808: - Summary: UNION ALL after lookup join produces unexpected results Key: FLINK-36808 URL: https://issues.apache.org/jira/browse/FLINK-36808 Project: Flink Iss

[jira] [Updated] (FLINK-36808) UNION ALL after lookup join produces unexpected results

[ https://issues.apache.org/jira/browse/FLINK-36808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36808: -- Description: Here is the SQL to reproduce the issue: {code:java} -- Data of table `stream`: --

[jira] [Resolved] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-16155. --- Resolution: Fixed > Translate "Operator/Process Function" into Chinese > ---

[jira] [Assigned] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-16155: - Assignee: BoShuai Li > Translate "Operator/Process Function" into Chinese > ---

[jira] [Commented] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898544#comment-17898544 ] Qingsheng Ren commented on FLINK-16155: --- master: 5bea35ebb65fae443b74f351869536257

[jira] [Assigned] (FLINK-27632) Improve connector testing framework to support more cases

[ https://issues.apache.org/jira/browse/FLINK-27632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-27632: - Assignee: Poorvank Bhatia > Improve connector testing framework to support more cases >

[jira] [Commented] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885823#comment-17885823 ] Qingsheng Ren commented on FLINK-36245: --- master: f2d6b5753dbf1a9fae3f6404100ce69da

[jira] [Resolved] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-36245. --- Resolution: Fixed > Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated

[jira] [Commented] (FLINK-36226) Build Flink CDC 3.2 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-36226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879504#comment-17879504 ] Qingsheng Ren commented on FLINK-36226: --- flink-cdc master: 4b4b8ea5bba9a723ac5aae1

[jira] [Created] (FLINK-36226) Build Flink CDC 3.2 Documentation and mark it as stable

Qingsheng Ren created FLINK-36226: - Summary: Build Flink CDC 3.2 Documentation and mark it as stable Key: FLINK-36226 URL: https://issues.apache.org/jira/browse/FLINK-36226 Project: Flink Iss

[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

[ https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35234: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Fix NullPointerException of

[jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function

[ https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35664: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Flink CDC pipeline transfor

[jira] [Updated] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.

[ https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35093: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Postgres source connector s

[jira] [Updated] (FLINK-35760) [docs] Add scan.newly-added-table.enabled to docs.

[ https://issues.apache.org/jira/browse/FLINK-35760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35760: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > [docs] Add scan.newly-added

[jira] [Updated] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled

[ https://issues.apache.org/jira/browse/FLINK-35757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35757: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > support read new tables whe

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34750: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34749: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34737: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "Deployment - Kubernetes" P

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34730: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Translate pages of Flink CD

[jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34752: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34595: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Fix ClassNotFoundException:

[jira] [Updated] (FLINK-34688) CDC framework split snapshot chunks asynchronously

[ https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34688: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > CDC framework split snapsho

[jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34736: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "Deployment - Standalone" P

[jira] [Updated] (FLINK-35759) [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs.

[ https://issues.apache.org/jira/browse/FLINK-35759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35759: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > [docs] Add 'scan.increment

[jira] [Updated] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.

[ https://issues.apache.org/jira/browse/FLINK-35873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35873: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Add HashFunctionProvider fo

[jira] [Updated] (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 ] Qingsheng Ren updated FLINK-34738: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "Deployment - YARN" Page fo

[jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34748: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-35167) Introduce MaxCompute pipeline DataSink

[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35167: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Introduce MaxCompute pipeli

[jira] [Updated] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35067: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Support metadata 'op_type'

[jira] [Updated] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect

[ https://issues.apache.org/jira/browse/FLINK-35349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35349: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Use connection in openJdbcC

[jira] [Updated] (FLINK-35385) upgrader flink dependency version to 1.19

[ https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35385: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > upgrader flink dependency v

[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector

[ https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35071: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Remove dependency on flink-

[jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore

[ https://issues.apache.org/jira/browse/FLINK-35444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35444: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Paimon Pipeline Connector s

[jira] [Updated] (FLINK-35450) Introduce Tikv pipeline DataSource

[ https://issues.apache.org/jira/browse/FLINK-35450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35450: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Introduce Tikv pipeline Dat

[jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-35589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35589: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Support MemorySize type in

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent correctly.

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36178: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Parse CREATE TABLE LIKE to

[jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart.

[ https://issues.apache.org/jira/browse/FLINK-35627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35627: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Avoid conflict when pipelin

[jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions

[ https://issues.apache.org/jira/browse/FLINK-35693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35693: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Change variable specificOff

[jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException.

[ https://issues.apache.org/jira/browse/FLINK-35718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35718: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Cherrypick DBZ-5333 to fix

[jira] [Updated] (FLINK-36174) CDC yaml without pipeline will throw NullPointException

[ https://issues.apache.org/jira/browse/FLINK-36174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36174: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > CDC yaml without pipeline w

[jira] [Updated] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name

[ https://issues.apache.org/jira/browse/FLINK-36111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36111: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > fix: adjust MultiTableCommi

[jira] [Updated] (FLINK-36219) Add Flink compatibility matrix of CDC releases

[ https://issues.apache.org/jira/browse/FLINK-36219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36219: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Add Flink compatibility mat

[jira] [Updated] (FLINK-36211) Shade kafka related package in Kafka Pipeline connector.

[ https://issues.apache.org/jira/browse/FLINK-36211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36211: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Shade kafka related package

[jira] [Updated] (FLINK-36220) Clean up typo and stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-36220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36220: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Clean up typo and stale lin

[jira] [Updated] (FLINK-36218) Documentations clean up before CDC 3.2.0 release

[ https://issues.apache.org/jira/browse/FLINK-36218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36218: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.2.0) > Documentations clean up bef

[jira] [Updated] (FLINK-36088) Fix NopointException in PaimonDataSink.

[ https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36088: -- Priority: Blocker (was: Critical) > Fix NopointException in PaimonDataSink. > ---

[jira] [Updated] (FLINK-36082) Fix NotSerializableException for KafkaDataSink

[ https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36082: -- Priority: Blocker (was: Major) > Fix NotSerializableException for KafkaDataSink > ---

[jira] [Closed] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version

[ https://issues.apache.org/jira/browse/FLINK-36055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-36055. - Fix Version/s: cdc-3.2.0 cdc-3.3.0 Resolution: Fixed > Change flink.co

[jira] [Commented] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version

[ https://issues.apache.org/jira/browse/FLINK-36055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873771#comment-17873771 ] Qingsheng Ren commented on FLINK-36055: --- flink-cdc master: c5396fbf29ae3a48bb13e38

[jira] [Assigned] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version

[ https://issues.apache.org/jira/browse/FLINK-36055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-36055: - Assignee: wuzexian > Change flink.connector.elasticsearch.version to a release version

[jira] [Commented] (FLINK-36054) Cleanup Flink CDC pom and release scripts

[ https://issues.apache.org/jira/browse/FLINK-36054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873769#comment-17873769 ] Qingsheng Ren commented on FLINK-36054: --- flink-cdc master: d99e718951f7541ba23321c

[jira] [Closed] (FLINK-36054) Cleanup Flink CDC pom and release scripts

[ https://issues.apache.org/jira/browse/FLINK-36054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-36054. - Resolution: Fixed > Cleanup Flink CDC pom and release scripts >

[jira] [Updated] (FLINK-36054) Cleanup Flink CDC pom and release scripts

[ https://issues.apache.org/jira/browse/FLINK-36054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-36054: -- Fix Version/s: cdc-3.2.0 cdc-3.3.0 > Cleanup Flink CDC pom and release scri

[jira] [Created] (FLINK-36054) Cleanup Flink CDC pom and release scripts

Qingsheng Ren created FLINK-36054: - Summary: Cleanup Flink CDC pom and release scripts Key: FLINK-36054 URL: https://issues.apache.org/jira/browse/FLINK-36054 Project: Flink Issue Type: Impro

[jira] [Resolved] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism

[ https://issues.apache.org/jira/browse/FLINK-35442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35442. --- Resolution: Fixed > Kafka Pipeline Sink may distribute the same key to different partitions

[jira] [Assigned] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism

[ https://issues.apache.org/jira/browse/FLINK-35442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35442: - Assignee: LvYanquan > Kafka Pipeline Sink may distribute the same key to different part

[jira] [Resolved] (FLINK-35791) Add database and table infos to Kafka json output.

[ https://issues.apache.org/jira/browse/FLINK-35791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35791. --- Assignee: LvYanquan Resolution: Fixed > Add database and table infos to Kafka json out

[jira] [Commented] (FLINK-35791) Add database and table infos to Kafka json output.

[ https://issues.apache.org/jira/browse/FLINK-35791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871903#comment-17871903 ] Qingsheng Ren commented on FLINK-35791: --- flink-cdc master: 9d6154f12307da24551a6f2

[jira] [Commented] (FLINK-35974) PyFlink YARN per-job on Docker test failed because docker-compose command not found

[ https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871240#comment-17871240 ] Qingsheng Ren commented on FLINK-35974: --- Probably caused by this: [https://github.

[jira] [Commented] (FLINK-35592) MysqlDebeziumTimeConverter miss timezone convert to timestamp

[ https://issues.apache.org/jira/browse/FLINK-35592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854943#comment-17854943 ] Qingsheng Ren commented on FLINK-35592: --- release-3.1: f476a5b1dd99fc63962bc75048c0

[jira] [Assigned] (FLINK-35592) MysqlDebeziumTimeConverter miss timezone convert to timestamp

[ https://issues.apache.org/jira/browse/FLINK-35592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35592: - Assignee: ZhengYu Chen > MysqlDebeziumTimeConverter miss timezone convert to timestamp

[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 ] Qingsheng Ren updated FLINK-35149: -- Fix Version/s: cdc-3.1.1 > Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not >

[jira] [Assigned] (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 ] Qingsheng Ren reassigned FLINK-35149: - Assignee: Hongshun Wang > Fix DataSinkTranslator#sinkTo ignoring pre-write topology if

[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=17851955#comment-17851955 ] Qingsheng Ren commented on FLINK-35149: --- flink-cdc master: 33891869a9fffa2abf8b8ae

[jira] [Assigned] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35386: - Assignee: Zhongqiang Gong (was: Qingsheng Ren) > Build Flink CDC 3.1 Documentation and

[jira] [Resolved] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35386. --- Resolution: Fixed > Build Flink CDC 3.1 Documentation and mark it as stable > --

[jira] [Commented] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847155#comment-17847155 ] Qingsheng Ren commented on FLINK-35386: --- flink-cdc master: 999027fbb1bc02109e8a79a

[jira] [Created] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

Qingsheng Ren created FLINK-35386: - Summary: Build Flink CDC 3.1 Documentation and mark it as stable Key: FLINK-35386 URL: https://issues.apache.org/jira/browse/FLINK-35386 Project: Flink Iss

[jira] [Resolved] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35309. --- Resolution: Fixed > Enable Notice file ci check and fix Notice > --

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34990: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [feature][cdc-connector][or

[jira] [Closed] (FLINK-34912) Replace all occurrences of com.ververica in the project with org.apache.flink

[ https://issues.apache.org/jira/browse/FLINK-34912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-34912. - Resolution: Duplicate > Replace all occurrences of com.ververica in the project with org.apache.

[jira] [Updated] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34908: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature][Pipeline] Mysql p

[jira] [Updated] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34904: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature] submit Flink CDC

[jira] [Assigned] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34752: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documenta

[jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34752: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34750: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34750: - Assignee: Hongshun Wang > "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC C

[jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34748: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34749: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34748: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documen

[jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34747: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34749: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese > D

[jira] [Assigned] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34747: - Assignee: Xiao Huang > "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Doc

[jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34735: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Developer Guide - Understa

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

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34736: - Assignee: Vincent Woo > "Deployment - Standalone" Page for Flink CDC Chinese Documentat

[jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34736: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - Standalone" P

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34730: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Translate pages of Flink CD

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35354: -- Fix Version/s: (was: cdc-3.1.0) > Support host mapping in Flink tikv cdc > ---

[jira] [Resolved] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35259. --- Resolution: Fixed > FlinkCDC Pipeline transform can't deal timestamp field > ---

[jira] [Comment Edited] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841824#comment-17841824 ] Qingsheng Ren edited comment on FLINK-35259 at 5/17/24 3:24 AM: --

[jira] [Updated] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

[ https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34944: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Use Incremental Source Fram

[jira] [Assigned] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

[ https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34944: - Assignee: He Wang > Use Incremental Source Framework in Flink CDC OceanBase Source Conn

[jira] [Updated] (FLINK-34853) [Feature] submit Flink CDC pipeline job to k8s cluster.

[ https://issues.apache.org/jira/browse/FLINK-34853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34853: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature] submit Flink CDC

[jira] [Updated] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34737: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - Kubernetes" P

[jira] [Updated] (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 ] Qingsheng Ren updated FLINK-34738: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - YARN" Page fo

[jira] [Updated] (FLINK-34638) Support default value of table column.

[ https://issues.apache.org/jira/browse/FLINK-34638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34638: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Support default value of ta

[jira] [Resolved] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

[ https://issues.apache.org/jira/browse/FLINK-34614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34614. --- Assignee: LvYanquan Resolution: Fixed > Add e2e test for Flink CDC pipeline job. > ---

[jira] [Updated] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34595: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Fix ClassNotFoundException:

[jira] [Commented] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845257#comment-17845257 ] Qingsheng Ren commented on FLINK-35309: --- CDC release-3.1: e452d66b3bfabbab9875d8d

[jira] [Assigned] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35309: - Assignee: Zhongqiang Gong > Enable Notice file ci check and fix Notice > -

  1   2   3   4   5   6   7   8   9   10   >