issues
Thread
Date
Later messages
Messages by Date
2026/03/25
Re: [PR] [FLINK-39187][table] Add core built-in aggregate functions for BITMAP [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38976][runtime] Support multiple batch jobs in an application [flink]
via GitHub
2026/03/25
[PR] [infra] Update github PR labeler after release 0.2.1. [flink-agents]
via GitHub
2026/03/25
[PR] [doc] Update documents after release 0.2.1 [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
[jira] [Created] (FLINK-39327) Rename gaussdws pipeline sink connector to dws
Daishuyuan (Jira)
2026/03/25
Re: [PR] [runtime] Filter resumed currentProcessingKeys by subtask ownership a… [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39233][table-runtime] Support cascaded delta join runtime [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39326][runtime] Fix DispatcherApplicationTest.testJobResultNot… [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39326) Flaky DispatcherApplicationTest.testJobResultNotMarkedCleanUntilApplicationTerminates
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-39326][runtime] Fix DispatcherApplicationTest.testJobResultNot… [flink]
via GitHub
2026/03/25
[jira] [Assigned] (FLINK-39264) Add docs for application management
Zhu Zhu (Jira)
2026/03/25
[jira] [Closed] (FLINK-39240) Jobs share application-level jar when possible
Zhu Zhu (Jira)
2026/03/25
Re: [PR] [FLINK-39240][runtime] Jobs share application-level jar when possible [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
[jira] [Closed] (FLINK-39325) Dynamically show/hide rescales tab
Chanhae Oh (Jira)
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [D] Agent Skills Integration Design [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-39284][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't respect schema of existing table [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39284][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't respect schema of existing table [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39284][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't respect schema of existing table [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39284][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't respect schema of existing table [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39284][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't respect schema of existing table [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39284][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't respect schema of existing table [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39235] Simplify body processing for GenericJsonAndUrlQueryCreator [flink-connector-http]
via GitHub
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39264) Add docs for application management
ASF GitHub Bot (Jira)
2026/03/25
Re: [PR] [FLINK-39264][docs] Add docs for application management [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39308][runtime] Skip empty file-merging operator state snapshots [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39308][runtime] Skip empty file-merging operator state snapshots [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39313][table] Fix NDU analyzer to detect non-deterministic functions in ChangelogNormalize filter conditions [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-36843][table-planner] Remove deprecated method in table-planner [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39313][table] Fix NDU analyzer to detect non-deterministic functions in ChangelogNormalize filter conditions [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38209][FLINK-38379][FLINK-38554][FLINK-38576][FLINK-38230][table] Backport multiple MultiJoin fixes to 2.1 [flink]
via GitHub
2026/03/25
[PR] [FLINK-38209][FLINK-38379][FLINK-38554][FLINK-38576][FLINK-38230][table] Backport multiple MultiJoin fixes to 2.1 [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39235] Simplify body processing for GenericJsonAndUrlQueryCreator [flink-connector-http]
via GitHub
2026/03/25
[jira] [Closed] (FLINK-39318) Interruptible timers are not actually enabled for temporal sort and joins
Piotr Nowojski (Jira)
2026/03/25
Re: [PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin and TemporalSort [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39318) Interruptible timers are not actually enabled for temporal sort and joins
Piotr Nowojski (Jira)
2026/03/25
Re: [PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin and TemporalSort [flink]
via GitHub
2026/03/25
[jira] [Commented] (FLINK-39326) Flaky DispatcherApplicationTest.testJobResultNotMarkedCleanUntilApplicationTerminates
Piotr Nowojski (Jira)
2026/03/25
[jira] [Created] (FLINK-39326) Flaky DispatcherApplicationTest.testJobResultNotMarkedCleanUntilApplicationTerminates
Piotr Nowojski (Jira)
2026/03/25
[jira] [Closed] (FLINK-39311) Flaky tests in DispatcherApplicationTest
Piotr Nowojski (Jira)
2026/03/25
Re: [PR] [FLINK-39311][runtime] Fix application-related main thread execution … [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39311][runtime] Fix application-related main thread execution … [flink]
via GitHub
2026/03/25
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39187][table] Add core built-in aggregate functions for BITMAP [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [docs] Reorder Flink CDC version mapping tables in descending order [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
[PR] [docs] Reorder Flink CDC version mapping tables in descending order [flink-cdc]
via GitHub
2026/03/25
[jira] [Reopened] (FLINK-39325) Dynamically show/hide rescales tab
Chanhae Oh (Jira)
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
[jira] [Closed] (FLINK-39325) Dynamically show/hide rescales tab
Chanhae Oh (Jira)
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39316][runtime] Fix BlobServer address resolution failing with VPN networking [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
[jira] [Created] (FLINK-39325) Dynamically show/hide rescales tab
CHANHAE OH (Jira)
2026/03/25
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/03/25
Re: [D] [Feature] Enhance the quickstart experience [flink-agents]
via GitHub
2026/03/25
[I] [Feature] Import Wizard for Installation Setup [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39233][table-runtime] Support cascaded delta join runtime [flink]
via GitHub
2026/03/25
[jira] [Closed] (FLINK-39174) Support lookup join after delta join
Xuyang Zhong (Jira)
2026/03/25
[jira] [Updated] (FLINK-39288) Update document description to guide users on using Flink 2. x version
ASF GitHub Bot (Jira)
2026/03/25
[jira] [Commented] (FLINK-39174) Support lookup join after delta join
Xuyang Zhong (Jira)
2026/03/25
[PR] [FLINK-39288][docs] Update DataStream API package guidance for Flink 1.20.x and 2.2.x [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [FLINK-39174][table-planner] Support lookup join after delta join [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-39233][table-runtime] Support cascaded delta join runtime [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [Tech Debt]Add cross-language resource consistency checking tool [flink-agents]
via GitHub
2026/03/25
[jira] [Closed] (FLINK-39314) Filter on any upsert key group is sufficient to discard update before in FlinkChangelogModeInferenceProgram
Xuyang Zhong (Jira)
2026/03/25
[jira] [Closed] (FLINK-39287) Introduce FlinkRelMdImmutableColumns to implement the derivation logic of some simple nodes
Xuyang Zhong (Jira)
2026/03/25
[jira] [Commented] (FLINK-39314) Filter on any upsert key group is sufficient to discard update before in FlinkChangelogModeInferenceProgram
Xuyang Zhong (Jira)
2026/03/25
[jira] [Commented] (FLINK-39286) Introduce immutable columns constraint in schema
Xuyang Zhong (Jira)
2026/03/25
[jira] [Closed] (FLINK-39286) Introduce immutable columns constraint in schema
Xuyang Zhong (Jira)
2026/03/25
[jira] [Commented] (FLINK-39287) Introduce FlinkRelMdImmutableColumns to implement the derivation logic of some simple nodes
Xuyang Zhong (Jira)
2026/03/25
[jira] [Assigned] (FLINK-39287) Introduce FlinkRelMdImmutableColumns to implement the derivation logic of some simple nodes
Xuyang Zhong (Jira)
2026/03/25
Re: [PR] [ci] Remove action astral-sh/setup-uv@v4 in ci due to legal issue. [flink-agents]
via GitHub
2026/03/25
Re: [PR] [infra] Ensure pip is installed in venv. [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-39286][table] Introduce immutable columns constraint in schema [flink]
via GitHub
2026/03/25
Re: [PR] [infra] Ensure pip is installed in venv. [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-39324][table-planner] Allow MultiJoin to respect IS_NOT_DISTICT_FROM when extracting join keys [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39324) Allow MultiJoin to respect IS_NOT_DISTINCT_FROM when extracting join keys
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-39324][table-planner] Allow MultiJoin to respect IS_NOT_DISTICT_FROM when extracting join keys [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-38901) Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39310][web-ui] Use programArgsList in JSON body instead of program-args query parameter [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39310) Web UI jar.service.ts passes program-args as string instead of programArgsList array, incompatible with Flink 2.0 REST API
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-39310][web-ui] Use programArgsList in JSON body instead of program-args query parameter [flink]
via GitHub
2026/03/25
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39324) Allow MultiJoin to respect IS_NOT_DISTINCT_FROM when extracting join keys
Stepan Stepanishchev (Jira)
2026/03/25
Re: [PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin and TemporalSort [flink]
via GitHub
2026/03/25
[jira] [Created] (FLINK-39324) Allow MultiJoin to respect IS_NOT_DISTINCT_FROM when extracting join keys
Stepan Stepanishchev (Jira)
2026/03/25
[PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin and TemporalSort [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink]
via GitHub
2026/03/25
[jira] [Created] (FLINK-39323) Support SHOW CREATE [OR ALTER] with relative time intervals for FROM_NOW(<interval_expression>)
Ramin Gharib (Jira)
2026/03/25
Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc]
via GitHub
2026/03/25
[jira] [Closed] (FLINK-39186) Add core built-in scalar functions for BITMAP
lincoln lee (Jira)
2026/03/25
[jira] [Updated] (FLINK-39302) Support SHOW CREATE OR ALTER MATERIALIZED TABLE
Ramin Gharib (Jira)
2026/03/25
[jira] [Updated] (FLINK-39302) Support SHOW CREATE OR ALTER MATERIALIZED TABLE
Ramin Gharib (Jira)
2026/03/25
[jira] [Resolved] (FLINK-39186) Add core built-in scalar functions for BITMAP
lincoln lee (Jira)
2026/03/25
Re: [PR] [FLINK-39186][table] Add core built-in scalar functions for BITMAP [flink]
via GitHub
2026/03/25
Re: [PR] [runtime] Filter resumed currentProcessingKeys by subtask ownership a… [flink-agents]
via GitHub
2026/03/25
Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/25
Re: [PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/25
Re: [PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39318) Interruptible timers are not actually enabled for temporal joins
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin [flink]
via GitHub
2026/03/25
Re: [PR] [FLINK-36843][table-planner] Remove deprecated method in table-planner [flink]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-36843) Remove deprecated method in flink-table-planner
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-36843][table-planner] Remove deprecated method in table-planner [flink]
via GitHub
2026/03/25
Re: [PR] Flink 39321 [flink-cdc]
via GitHub
2026/03/25
[PR] Flink 39321 [flink-cdc]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/25
Re: [PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
Re: [D] Agent Skills Integration Design [flink-agents]
via GitHub
2026/03/25
Re: [D] Agent Skills Integration Design [flink-agents]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/25
Re: [PR] Add FlinkCDC v3.6.0. [flink-web]
via GitHub
2026/03/25
[jira] [Updated] (FLINK-39294) [DOC] Add documentation for PostgreSQL CDC `schema.change.enabled` option
ASF GitHub Bot (Jira)
2026/03/25
[PR] [FLINK-39294][docs][postgres][fluss] Add document about schema evolution from postgres to fluss. [flink-cdc]
via GitHub
2026/03/25
Re: [PR] [mcp] Change PromptArgument.required from boolean to Boolean and default null to false [flink-agents]
via GitHub
2026/03/25
Re: [D] Flink Agents Release Process [flink-agents]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-39187) Add core built-in aggregate functions for BITMAP
ASF GitHub Bot (Jira)
2026/03/24
Re: [PR] [FLINK-39187][table] Add core built-in aggregate functions for BITMAP [flink]
via GitHub
2026/03/24
Re: [PR] [FLINK-38727] Fix flaky test by adding slot request timeout configura… [flink]
via GitHub
2026/03/24
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
2026/03/24
[PR] Flink 39187 [flink]
via GitHub
2026/03/24
[jira] [Commented] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect
Hao Li (Jira)
2026/03/24
Re: [PR] [FLINK-38507] OpenTelemetryTraceReporterITCase failed in Test - connect [flink]
via GitHub
2026/03/24
[jira] [Resolved] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state
Yuepeng Pan (Jira)
2026/03/24
Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state
Yuepeng Pan (Jira)
2026/03/24
[jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest
Yuepeng Pan (Jira)
2026/03/24
Re: [PR] [FLINK-38822] Introduce URL_DECODE_RECURSIVE function for recursive URL decoding [flink]
via GitHub
2026/03/24
[jira] [Commented] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core
Hao Li (Jira)
2026/03/24
Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink]
via GitHub
2026/03/24
[jira] [Commented] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely
Hao Li (Jira)
2026/03/24
Re: [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink]
via GitHub
2026/03/24
[jira] [Created] (FLINK-39322) Add some restore tests about cascaded delta join
Xuyang Zhong (Jira)
2026/03/24
Re: [D] Agent Skills Integration Design [flink-agents]
via GitHub
2026/03/24
[jira] [Assigned] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Leonard Xu (Jira)
2026/03/24
[jira] [Commented] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
Hao Li (Jira)
2026/03/24
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
2026/03/24
[jira] [Commented] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow
Hao Li (Jira)
2026/03/24
Re: [PR] [FLINK-38727] Fix flaky test by adding slot request timeout configura… [flink]
via GitHub
2026/03/24
[jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails
Hao Li (Jira)
2026/03/24
[PR] [infra] Ensure pip is installed in venv. [flink-agents]
via GitHub
2026/03/24
Re: [PR] [mcp] Change PromptArgument.required from boolean to Boolean and default null to false [flink-agents]
via GitHub
2026/03/24
Re: [PR] [runtime] Filter resumed currentProcessingKeys by subtask ownership a… [flink-agents]
via GitHub
2026/03/24
Re: [PR] [FLINK-38828][cdc-common][cdc-runtime] Handle schema evolution upon projection updates via SchemaCoordinator [flink-cdc]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/24
Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/24
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/24
Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc]
via GitHub
2026/03/24
Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc]
via GitHub
2026/03/24
Re: [PR] [build] Update version to 3.7-SNAPSHOT [flink-cdc]
via GitHub
2026/03/24
Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-39312) Fix Hudi pipeline connector dependency scope for flink-metrics-dropwizard
Leonard Xu (Jira)
2026/03/24
[jira] [Assigned] (FLINK-39315) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase when the MySql table is being continuously written
Leonard Xu (Jira)
2026/03/24
Re: [PR] [mcp] Change PromptArgument.required from boolean to Boolean and default null to false [flink-agents]
via GitHub
2026/03/24
Re: [PR] [FLINK-39186][table] Add core built-in scalar functions for BITMAP [flink]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/24
[jira] [Updated] (FLINK-39321) Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID error.
Jira
2026/03/24
Re: [PR] [FLINK-39286][table] Introduce immutable columns constraint in schema [flink]
via GitHub
2026/03/24
[jira] [Created] (FLINK-39321) When writing to Paimon via FlinkCDC , if 'dynamic-bucket.initial-buckets' = '1' is set and the job parallelism is greater than 1, an error will be reported: This is a bug, record assign id %s should equal to assign id %s.
Jira
2026/03/24
[jira] [Updated] (FLINK-39320) Include Kafka record metadata in deserialization error message
ASF GitHub Bot (Jira)
2026/03/24
[PR] [FLINK-39320] Include Kafka record metadata in deserialization error message [flink-connector-kafka]
via GitHub
2026/03/24
[jira] [Updated] (FLINK-39320) Include Kafka record metadata in deserialization error message
Pritesh Gudge (Jira)
2026/03/24
Re: [PR] [ci] Remove action astral-sh/setup-uv@v4 in ci due to legal issue. [flink-agents]
via GitHub
2026/03/24
Re: [PR] [FLINK-39240][runtime] Jobs share application-level jar when possible [flink]
via GitHub
2026/03/24
Re: [PR] [FLINK-39240][runtime] Jobs share application-level jar when possible [flink]
via GitHub
2026/03/24
Re: [PR] [FLINK-39240][runtime] Jobs share application-level jar when possible [flink]
via GitHub
Later messages