issues  

Messages by Date

• 2026/07/02 [jira] [Created] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml lisa (Jira)
• 2026/07/02 [jira] [Closed] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40047) Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40047) Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40034) Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 Purushottam Sinha (Jira)
• 2026/07/02 [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• 2026/07/02 [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• 2026/07/02 Re: [PR] [FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/07/02 Re: [PR] [FLINK-40031][runtime-web] Fix Exceptions view crash navigating to an unassigned TaskManager [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-31849] Adds basic CRD validations [flink-kubernetes-operator] via GitHub
• 2026/07/02 [jira] [Assigned] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism Leonard Xu (Jira)
• 2026/07/02 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/07/02 [jira] [Commented] (FLINK-40033) Modernize web-dashboard visualization libraries Purushottam Sinha (Jira)
• 2026/07/02 Re: [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-34610] Migrate `StreamPhysicalLimitRule` from Scala to Java [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-34610] Migrate `StreamPhysicalLimitRule` from Scala to Java [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] via GitHub
• 2026/07/02 [jira] [Created] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore Martijn Visser (Jira)
• 2026/07/02 Re: [PR] [FLINK-37448] Report actual TaskManager count in status.taskManager.replicas [flink-kubernetes-operator] via GitHub
• 2026/07/01 Re: [PR] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/07/01 [jira] [Commented] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect Hongshun Wang (Jira)
• 2026/07/01 [jira] [Comment Edited] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Chanhae Oh (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Chanhae Oh (Jira)
• 2026/07/01 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/01 [jira] [Created] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x Taranpreet Kaur (Jira)
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Chanhae Oh (Jira)
• 2026/07/01 Re: [PR] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39968] [core] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance [flink] via GitHub
• 2026/07/01 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/07/01 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39839][table] Supports timeout in AsyncTableFunction [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39839][table] Supports timeout in AsyncTableFunction [flink] via GitHub
• 2026/07/01 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/07/01 [I] [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase. [flink-agents] via GitHub
• 2026/07/01 [I] [Tech Debt] Update install.sh after releasing 0.3.0 [flink-agents] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead ASF GitHub Bot (Jira)
• 2026/07/01 [PR] [FLINK-40038][pipeline-connector/mysql] Cache inferred row DataType in MySQL deserialization [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Purushottam Sinha (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40045) Upgrade d3-flame-graph to v5 Purushottam Sinha (Jira)
• 2026/07/01 Re: [PR] [dist] Add Flink 2.3 distribution and make it the default [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 [jira] [Created] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/01 [jira] [Assigned] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/01 [jira] [Closed] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Martijn Visser (Jira)
• 2026/07/01 [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 Re: [PR] Bump ip-address and socks in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump fast-uri from 3.0.3 to 3.1.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump fast-uri from 3.0.3 to 3.1.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @babel/plugin-transform-modules-systemjs from 7.27.1 to 7.29.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump ip-address and socks in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @babel/plugin-transform-modules-systemjs from 7.27.1 to 7.29.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @babel/plugin-transform-modules-systemjs from 7.27.1 to 7.29.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump follow-redirects from 1.15.9 to 1.16.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump follow-redirects from 1.15.9 to 1.16.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump idna from 3.11 to 3.15 in /flink-python/docs [flink] via GitHub
• 2026/07/01 Re: [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /flink-python/docs [flink] via GitHub
• 2026/07/01 Re: [PR] Bump ip-address and socks in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump fast-uri from 3.0.3 to 3.1.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump follow-redirects from 1.15.9 to 1.16.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump pygments from 2.19.2 to 2.20.0 in /flink-python/docs [flink] via GitHub
• 2026/07/01 Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump immutable from 5.1.3 to 5.1.5 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump immutable from 5.1.3 to 5.1.5 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump immutable from 5.1.3 to 5.1.5 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/core from 20.1.3 to 20.3.18 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/core from 20.1.3 to 20.3.18 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/compiler from 20.1.3 to 20.3.18 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/compiler from 20.1.3 to 20.3.18 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/core from 20.1.3 to 20.3.18 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/compiler from 20.1.3 to 20.3.18 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery ASF GitHub Bot (Jira)
• 2026/07/01 [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 Re: [PR] Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump undici and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump js-yaml from 4.1.0 to 4.3.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/core from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/core from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump launch-editor from 2.11.0 to 2.14.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 [jira] [Closed] (FLINK-39518) Upgrade web-dashboard dependencies to major remaining npm advisories Martijn Visser (Jira)
• 2026/07/01 Re: [PR] Bump js-yaml from 4.1.0 to 4.3.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/compiler from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump launch-editor from 2.11.0 to 2.14.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/compiler from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @sigstore/core and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @sigstore/core and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/common from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 [jira] [Closed] (FLINK-39517) Resolve SemVer-compatible npm advisories in web-dashboard Martijn Visser (Jira)
• 2026/07/01 [PR] Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump shell-quote from 1.8.3 to 1.8.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump shell-quote from 1.8.3 to 1.8.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @angular/common from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 [PR] Bump undici and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 [jira] [Closed] (FLINK-39516) [web dashboard] Address npm security advisories in flink-runtime-web web-dashboard Martijn Visser (Jira)
• 2026/07/01 Re: [PR] [FLINK-39516][runtime-web] Address npm security advisories in flink-runtime-web web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39516][runtime-web] Address npm security advisories in flink-runtime-web web-dashboard [flink] via GitHub
• 2026/07/01 [jira] [Resolved] (FLINK-40028) Update Angular to v21 and ng-zorro-antd to v21 Martijn Visser (Jira)
• 2026/07/01 Re: [PR] [FLINK-40028][runtime-web] Update Angular to v21 and ng-zorro-antd to v21 [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40046) Upgrade @antv/g2 to v5 ASF GitHub Bot (Jira)
• 2026/07/01 [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink] via GitHub
• 2026/07/01 [jira] [Commented] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ ASF GitHub Bot (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40047) Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/01 [PR] [FLINK-40047] [Kubernetes Operator] Support Flink 2.0+ in standalone JobManager decorator [flink-kubernetes-operator] via GitHub
• 2026/07/01 [jira] [Created] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/07/01 [jira] [Resolved] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/07/01 Re: [PR] [FLINK-38536][tests] Deploy synchronously to avoid deployment-callback race [flink] via GitHub
• 2026/07/01 [jira] [Resolved] (FLINK-35539) The artifactId of flink-migration-test-utils module has a typo Sergey Nuyanzin (Jira)
• 2026/07/01 [jira] [Assigned] (FLINK-35539) The artifactId of flink-migration-test-utils module has a typo Sergey Nuyanzin (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-40045) Upgrade d3-flame-graph to v5 Purushottam Sinha (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-35539) The artifactId of flink-migration-test-utils module has a typo Sergey Nuyanzin (Jira)
• 2026/07/01 [jira] [Closed] (FLINK-35539) The artifactId of flink-migration-test-utils module has a typo Sergey Nuyanzin (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Purushottam Sinha (Jira)
• 2026/07/01 [jira] [Created] (FLINK-40046) Upgrade @antv/g2 to v5 Purushottam Sinha (Jira)
• 2026/07/01 [jira] [Created] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Purushottam Sinha (Jira)
• 2026/07/01 [jira] [Created] (FLINK-40045) Upgrade d3-flame-graph to v5 Purushottam Sinha (Jira)
• 2026/07/01 Re: [PR] [FLINK-40033][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/01 [PR] [FLINK-40033][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39622] [postgres] Fix O(N²) JDBC metadata lookups in CustomPostgresSchema d… [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40033][runtime-web] Replace unmaintained dagre with @dagrejs/dagre 3.x [flink] via GitHub
• 2026/07/01 [jira] [Assigned] (FLINK-40033) Modernize web-dashboard visualization libraries Martijn Visser (Jira)
• 2026/07/01 Re: [PR] [BP-2.3][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 [PR] [FLINK-40033][runtime-web] Replace unmaintained dagre with @dagrejs/dagre 3.x [flink] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40033) Modernize web-dashboard visualization libraries ASF GitHub Bot (Jira)
• 2026/07/01 Re: [PR] [FLINK-39946][runtime] Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-38919][docs] Document PyFlink per-cluster offsets [flink-connector-kafka] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Roman Khachatryan (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Roman Khachatryan (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Roman Khachatryan (Jira)
• 2026/07/01 Re: [PR] chore: move common CI scripts out of tools/azure-pipelines [flink] via GitHub
• 2026/07/01 Re: [PR] feat: add docs check to pull requests [flink] via GitHub
• 2026/07/01 Re: [PR] feat: new baseline nightly build [flink] via GitHub
• 2026/07/01 Re: [PR] feat: add nightly snapshot releases to GHA pipeline [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40031][runtime-web] Fix Exceptions view crash navigating to an unassigned TaskManager [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39956][metrics] Add heap memory pool metrics (Used/Max/CollectionUsed/CollectionMax) [flink] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager ASF GitHub Bot (Jira)
• 2026/07/01 [PR] [FLINK-40031][runtime-web] Fix Exceptions view crash navigating to an unassigned TaskManager [flink] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-39956) Expose per-pool heap CollectionUsage gauges ASF GitHub Bot (Jira)
• 2026/07/01 Re: [PR] [test] Try to Fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40028][runtime-web] Update Angular to v21 and ng-zorro-antd to v21 [flink] via GitHub
• 2026/07/01 Re: [PR] [BP-2.3][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 Re: [PR] [BP-2.2][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 Re: [PR] [BP-2.1][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 [PR] [BP-2.3][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 [PR] [BP-2.2][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 [PR] [BP-2.1][FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism ASF GitHub Bot (Jira)
• 2026/07/01 [PR] [FLINK-40043] fix the paimon pipeline job couldn’t increase job parallelism. [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40030][connector-http] Add architecture tests [flink-connector-http] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40040][cdc-runtime] Wrap coordinator failure in SerializedThrowable across the RPC boundary [flink-cdc] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism peiyu (Jira)
• 2026/07/01 [jira] [Created] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism peiyu (Jira)
• 2026/07/01 Re: [PR] [test] Try to Fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Mika Naylor (Jira)
• 2026/07/01 Re: [PR] [FLINK-40028][runtime-web] Update Angular to v21 and ng-zorro-antd to v21 [flink] via GitHub
• 2026/07/01 [jira] [Created] (FLINK-40042) Update JDBC connector version to 4.1.0 Yuepeng Pan (Jira)

• Earlier messages
• Later messages