issues  

Messages by Thread

• • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] via GitHub
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] via GitHub
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] via GitHub
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] via GitHub
• [jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Mate Czagany (Jira)
• [jira] [Updated] (FLINK-38966) Update rsync Github Actions to 8.0.2 ASF GitHub Bot (Jira)
• [PR] [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) [flink] via GitHub
  • Re: [PR] [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for legacy doc build [flink] via GitHub
  • Re: [PR] [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for legacy doc build [flink] via GitHub
• [jira] [Created] (FLINK-38966) Update rsync Github Actions to 8.0.2 Martijn Visser (Jira)
• [jira] [Commented] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
  • [jira] [Commented] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
• [jira] [Updated] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
  • [jira] [Updated] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
  • [jira] [Updated] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
  • [jira] [Updated] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
• [PR] [api] Introduce Hierarchical ResourceName for Cross-Language Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
  • Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38799) Rename "LoadingWeight" to "TaskExecutionLoad" Yuepeng Pan (Jira)
• Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint Roman Khachatryan (Jira)
• [jira] [Closed] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint Roman Khachatryan (Jira)
• [PR] [doc] Add built-in resource providers overview page [flink-agents] via GitHub
  • Re: [PR] [doc] Add built-in resource providers overview page [flink-agents] via GitHub
  • Re: [PR] [doc] Add documentation about how to choose between Java & Python APIs [flink-agents] via GitHub
  • Re: [PR] [doc] Add documentation about how to choose between Java & Python APIs [flink-agents] via GitHub
• [PR] [doc] Update document for vector store. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for vector store. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for vector store. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for vector store. [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-38886) Provide GenericRecordData in Pipeline public API Yanquan Lv (Jira)
• [I] [Feature] Introduce Hierarchical `ResourceClassName` for Cross-Language Resource Creation [flink-agents] via GitHub
  • Re: [I] [Feature] Introduce Hierarchical `ResourceClassName` for Cross-Language Resource Creation [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38777) HistoryServer supports application archives Zhu Zhu (Jira)
• [PR] [doc] Add java Anthropic chat model docs [flink-agents] via GitHub
  • Re: [PR] [doc] Add java Anthropic chat model docs [flink-agents] via GitHub
  • Re: [PR] [doc] Add java Anthropic chat model docs [flink-agents] via GitHub
• Re: [I] [Feature] Support Cross-Language Resource [flink-agents] via GitHub
• Re: [I] [Feature][doc] Add document on how to use cross-language resources [flink-agents] via GitHub
• Re: [PR] [FLINK-38525][python] Fix coder doesn't process TIMESTAMP_LTZ correctly [flink] via GitHub
• Re: [PR] [FLINK-36753] Adaptive Scheduler actively triggers a Checkpoint [flink] via GitHub
• Re: [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `TaskExecutionLoad` [flink] via GitHub
  • Re: [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `TaskExecutionLoad` [flink] via GitHub
• [jira] [Updated] (FLINK-38699) Order the WebUI's Completed Job List by end time order ASF GitHub Bot (Jira)
• [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
  • Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
  • Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
  • Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
  • Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
  • Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
  • Re: [PR] [FLINK-38699][ui] Sort jobs by default [flink] via GitHub
• [jira] [Assigned] (FLINK-38699) Order the WebUI's Completed Job List by end time order Zhu Zhu (Jira)
• [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
  • Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
  • Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
  • Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
  • Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
  • Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
  • Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] via GitHub
• [PR] [FLINK-38964][table] Reuse Calcite's `SlqValidatorImpl#maybeCast` [flink] via GitHub
  • Re: [PR] [FLINK-38964][table] Reuse Calcite's `SqlValidatorImpl#maybeCast` [flink] via GitHub
  • Re: [PR] [FLINK-38964][table] Reuse Calcite's `SlqValidatorImpl#maybeCast` [flink] via GitHub
  • Re: [PR] [FLINK-38964][table] Reuse Calcite's `SqlValidatorImpl#maybeCast` [flink] via GitHub
  • Re: [PR] [FLINK-38964][table] Reuse Calcite's `SqlValidatorImpl#maybeCast` [flink] via GitHub
• [jira] [Commented] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely rstest (Jira)
• [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] via GitHub
  • Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] via GitHub
  • Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] via GitHub
  • Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] via GitHub
  • Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] via GitHub
  • Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] via GitHub
• Re: [PR] [FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records [flink-connector-kafka] via GitHub
• [jira] [Comment Edited] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Ferenc Csaky (Jira)
• [jira] [Comment Edited] (FLINK-36296) Add incremental shard discovery for DDB Streams source Ferenc Csaky (Jira)
• [jira] [Comment Edited] (FLINK-38783) Caused by: java.util.ConcurrentModificationException Rion Williams (Jira)
• [jira] [Updated] (FLINK-38783) Caused by: java.util.ConcurrentModificationException ASF GitHub Bot (Jira)
• [PR] Flink 38783 [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] via GitHub
• [jira] [Updated] (FLINK-38962) Add OpenSearch 3.x connector support ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38799) Rename "LoadingWeight" to "TaskExecutionLoad" Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-38799) Rename "LoadingWeight" to "TaskExecutionLoad" Ferenc Csaky (Jira)
• Re: [PR] [FLINK-37776][python] Drop python 3.8 support [flink] via GitHub
• [jira] [Updated] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns ASF GitHub Bot (Jira)
• [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
  • Re: [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
  • Re: [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
  • Re: [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
  • Re: [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
  • Re: [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
  • Re: [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] via GitHub
• [jira] [Created] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-38048) flink-connector-parent java version should be set to 11 Ferenc Csaky (Jira)
• [jira] [Commented] (FLINK-38783) Caused by: java.util.ConcurrentModificationException Rion Williams (Jira)
• [PR] Add AWS Connectors 6.0.0 [flink-web] via GitHub
• [jira] [Assigned] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Matthias Pohl (Jira)
• [jira] [Commented] (FLINK-38728) fullWindowPartition().reduce() is not being chained Zhe Wang (Jira)
  • [jira] [Commented] (FLINK-38728) fullWindowPartition().reduce() is not being chained Jacob Jona Fahlenkamp (Jira)
• [jira] [Updated] (FLINK-38728) fullWindowPartition().reduce() is not being chained Zhe Wang (Jira)
• [jira] [Created] (FLINK-38962) Add OpenSearch 3.x connector support Julian Dimitrov (Jira)
• [PR] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] via GitHub
  • Re: [PR] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] via GitHub
  • Re: [PR] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-38962][connectors/opensearch] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-38962][connectors/opensearch] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] via GitHub
• [jira] [Closed] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes Ferenc Csaky (Jira)
• [PR] Add error handling feature skip failed events [flink-connector-elasticsearch] via GitHub
  • Re: [PR] Add error handling feature skip failed events [flink-connector-elasticsearch] via GitHub
  • Re: [PR] Add error handling feature skip failed events [flink-connector-elasticsearch] via GitHub
  • [PR] Add error handling feature skip failed events [flink-connector-elasticsearch] via GitHub
  • Re: [PR] Add error handling feature skip failed events [flink-connector-elasticsearch] via GitHub
• [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses Sergey Nuyanzin (Jira)
• [jira] [Comment Edited] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses Sergey Nuyanzin (Jira)
• [PR] [doc] Add documents for memory of flink-agents. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for memory of flink-agents. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for memory of flink-agents. [flink-agents] via GitHub
  • Re: [PR] [doc] Add documents for memory of flink-agents. [flink-agents] via GitHub
• [jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler Yuepeng Pan (Jira)
• [PR] [hotfix] Handle durable execute exception properly [flink-agents] via GitHub
  • Re: [PR] [hotfix] Handle durable execute exception properly [flink-agents] via GitHub
• [jira] [Commented] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
• [jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
  • [jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
  • [jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
  • [jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
• [jira] [Created] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
• [jira] [Commented] (FLINK-38699) Order the WebUI's Completed Job List by end time order Liu (Jira)
• [jira] [Updated] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled ASF GitHub Bot (Jira)
• [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
  • Re: [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
  • Re: [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
  • Re: [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
  • Re: [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
  • Re: [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
  • Re: [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] via GitHub
• [jira] [Commented] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• [jira] [Updated] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes ASF GitHub Bot (Jira)
• [PR] [FLINK-38952] Fix PyFlink AWS code to the current java package [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-38952] Fix PyFlink AWS code to point to the current java package [flink-connector-aws] via GitHub
• [jira] [Updated] (FLINK-38953) Cleanup configurations for SSL hostname verification ASF GitHub Bot (Jira)
• [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] via GitHub
  • Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] via GitHub
  • Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] via GitHub
  • Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] via GitHub
  • Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] via GitHub
  • Re: [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] via GitHub
• [PR] [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading… [flink] via GitHub
  • Re: [PR] [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading… [flink] via GitHub
  • Re: [PR] [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading… [flink] via GitHub
  • Re: [PR] [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading… [flink] via GitHub
  • Re: [PR] [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading… [flink] via GitHub
• [I] [Tech Debt] Align default value for python and java openai chatmodel [flink-agents] via GitHub
• [PR] [doc] Add OpenAI chat model docs [flink-agents] via GitHub
  • Re: [PR] [doc] Add OpenAI chat model docs [flink-agents] via GitHub
• [PR] [FLINK-38950][table] `SqlNodeConvertUtils` should use validated query output [flink] via GitHub
  • Re: [PR] [FLINK-38950][table] `SqlNodeConvertUtils` should use validated query output [flink] via GitHub
  • Re: [PR] [FLINK-38950][table] `SqlNodeConvertUtils` should use validated query output [flink] via GitHub
• [jira] [Updated] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility Han Yin (Jira)
  • [jira] [Updated] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility Han Yin (Jira)
  • [jira] [Updated] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility Han Yin (Jira)
  • [jira] [Updated] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility Yuan Mei (Jira)
• [jira] [Created] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility Han Yin (Jira)
• [jira] [Closed] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Leonard Xu (Jira)
• [jira] [Updated] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Leonard Xu (Jira)
• [jira] [Reopened] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Leonard Xu (Jira)
• [jira] [Closed] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config Thorne (Jira)
• [jira] [Closed] (FLINK-37447) [Flink CDC] Supports Variant type in YAML API Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37924) Support variant field accessing Xuannan Su (Jira)
• [PR] [hotfix][docs] Add 2026 on NOTICE [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix][docs] Add 2026 on NOTICE [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix][docs] Add 2026 on NOTICE [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-38959) Added support for schema change in the postgres pipeline connector ASF GitHub Bot (Jira)
• [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38959) Added support for schema change in the postgres pipeline connector Jira
• [jira] [Assigned] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 Sergey Nuyanzin (Jira)

• Earlier messages
• Later messages