issues  

Messages by Thread

• • [jira] [Updated] (FLINK-39344) [Doc] Fix inconsistencies between MySqlDataSourceOptions and MySQL Pipeline Connector documentation XiaodongHuan (Jira)
  • [jira] [Updated] (FLINK-39344) [Doc] Fix inconsistencies between MySqlDataSourceOptions and MySQL Pipeline Connector documentation XiaodongHuan (Jira)
  • [jira] [Updated] (FLINK-39344) [Doc] Fix inconsistencies between MySqlDataSourceOptions and MySQL Pipeline Connector documentation ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39301) FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution ASF GitHub Bot (Jira)
• [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39301][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39304][table] Support `START_MODE` clause in the parser [flink] via GitHub
  • Re: [PR] [FLINK-39304][table] Support `START_MODE` clause in the parser [flink] via GitHub
• [jira] [Created] (FLINK-39344) [Doc] Fix inconsistencies between MySqlDataSourceOptions and MySQL Pipeline Connector documentation XiaodongHuan (Jira)
• [jira] [Assigned] (FLINK-39304) Support START_MODE clause in the parser Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39304) Support START_MODE clause in the parser Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39304) Support START_MODE clause in the parser Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39304) Support START_MODE clause in the parser Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39304) Support START_MODE clause in the parser Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39304) Support START_MODE clause in the parser Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39304) Support START_MODE clause in the parser ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-39305) Implement START_MODE for ALTER path of Materialized Table Sergey Nuyanzin (Jira)
• [PR] [hotfix] Fix SELECT statment in http.md [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix SELECT statment in http.md [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix SELECT statment in http.md [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix SELECT statement in http.md [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix SELECT statement in http.md [flink-connector-http] via GitHub
• Re: [PR] [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-39343) Fix inconsistencies in sql_function documentation ASF GitHub Bot (Jira)
• [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
  • Re: [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
  • Re: [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
  • Re: [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
  • Re: [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
  • Re: [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
  • Re: [PR] [FLINK-39343][doc] Fix inconsistencies in sql_function documentation [flink] via GitHub
• [jira] [Created] (FLINK-39343) Fix inconsistencies in sql_function documentation Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-39118) Add Documentation for native s3 fs ASF GitHub Bot (Jira)
• [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118][docs] Add documentation for Native s3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-39118][docs] Add documentation for Native s3 FileSystem [flink] via GitHub
• Re: [PR] [FLINK-39000] [runtime] Avoid redundant seeks during operator list state restore [flink] via GitHub
  • Re: [PR] [FLINK-39000] [runtime] Avoid redundant seeks during operator list state restore [flink] via GitHub
  • Re: [PR] [FLINK-39000] [runtime] Avoid redundant seeks during operator list state restore [flink] via GitHub
  • Re: [PR] [FLINK-39000] [runtime] Avoid redundant seeks during operator list state restore [flink] via GitHub
• Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-39288) Update document description to guide users on using Flink 2. x version Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-39338) Fix topic collision in parameterized KafkaWriter tests Rui Fan (Jira)
• Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
  • Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
  • Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
  • Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
  • Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
  • Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
• [jira] [Updated] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties ASF GitHub Bot (Jira)
• [PR] [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties [flink-cdc] via GitHub
• [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
  • Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
  • Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
  • Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
  • Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
  • Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
  • Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
• [PR] [hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39341) Implement DatabaseMetaData methods for DBeaver compatibility Navis Ryu (Jira)
  • [jira] [Updated] (FLINK-39341) Implement DatabaseMetaData methods for DBeaver compatibility ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties ericzeng (Jira)
• [jira] [Created] (FLINK-39341) Implement DatabaseMetaData methods for DBeaver compatibility Navis Ryu (Jira)
• [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
  • Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
  • Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
  • Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
  • Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
  • Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
• Re: [PR] Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Robert Metzger (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
• [jira] [Created] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
• [jira] [Commented] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• [jira] [Closed] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• [PR] [docs] Polish README.md [flink-cdc] via GitHub
  • Re: [PR] [docs] Polish README.md [flink-cdc] via GitHub
  • Re: [PR] [docs] Polish README.md [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type lincoln lee (Jira)
• [jira] [Commented] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type lincoln lee (Jira)
• [jira] [Closed] (FLINK-39188) Documentation for BITMAP type lincoln lee (Jira)
• [jira] [Resolved] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation ericzeng (Jira)
• [jira] [Updated] (FLINK-39339) Consider immutable cols to infer sink required updated mode traits ASF GitHub Bot (Jira)
• [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
  • Re: [PR] [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits [flink] via GitHub
• [jira] [Created] (FLINK-39339) Consider immutable cols to infer sink required updated mode traits Xuyang Zhong (Jira)
• Re: [PR] [FLINK-39300][mysql-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation. [flink-cdc] via GitHub
• [PR] [FLINK-39338] Fix topic name collisions in KafkaWriterTestBase for parameterized tests [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39338] Fix topic name collisions in KafkaWriterTestBase for parameterized tests [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39338] Fix topic name collisions in KafkaWriterTestBase for parameterized tests [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39338] Fix topic name collisions in KafkaWriterTestBase for parameterized tests [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-39338) Fix topic collision in parameterized KafkaWriter tests ASF GitHub Bot (Jira)
• [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Resolved] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled Rui Fan (Jira)
• Re: [PR] [FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled [flink] via GitHub
• [PR] [FLINK-39335] Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19 [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39335] Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19 [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-39338) Fix topic collision in parameterized KafkaWriter tests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39338) Fix topic collision in parameterized KafkaWriter tests Aleksandr Savonin (Jira)
• Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData [flink] via GitHub
• [jira] [Updated] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
  • Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
• [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
  • Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
• [jira] [Closed] (FLINK-39313) NDU analyzer misses non-deterministic functions in ChangelogNormalize filter conditions Timo Walther (Jira)
• [jira] [Created] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. peiyu (Jira)
• [jira] [Updated] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. ASF GitHub Bot (Jira)
• [PR] [FLINK-39337] Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39337] Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. peiyu (Jira)
• [jira] [Updated] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. ASF GitHub Bot (Jira)

• Earlier messages
• Later messages