issues  

Messages by Date

• 2026/07/05 [jira] [Resolved] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements Sergey Nuyanzin (Jira)
• 2026/07/05 [jira] [Commented] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements Sergey Nuyanzin (Jira)
• 2026/07/05 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/05 Re: [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink] via GitHub
• 2026/07/05 Re: [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink] via GitHub
• 2026/07/04 [jira] [Updated] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches ASF GitHub Bot (Jira)
• 2026/07/04 Re: [PR] [FLINK-40073] Add delete and force push protection to default and release branch [flink] via GitHub
• 2026/07/04 [jira] [Created] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches Harshit Gupta (Jira)
• 2026/07/04 [PR] Add delete and force push protection to default and release branch [flink] via GitHub
• 2026/07/04 [I] [Bug] ActionStateSerde: nested byte[] (and Long→Integer) type-loss in MemoryUpdate container values on durable replay [flink-agents] via GitHub
• 2026/07/04 [PR] [runtime] Preserve byte[] MemoryUpdate values across durable-execution serde (#865) [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/04 [jira] [Commented] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Qiu Yanjun (Jira)
• 2026/07/04 [jira] [Updated] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) ASF GitHub Bot (Jira)
• 2026/07/04 [PR] [FLINK-39429][cdc-base] Avoid shaded Guava in incremental source fetchers [flink-cdc] via GitHub
• 2026/07/04 Re: [I] [Bug] byte[] memory values corrupted to base64 String on the durable-execution replay path [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [python] Admit bytes in the Python memory value contract [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents] via GitHub
• 2026/07/04 [jira] [Commented] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting Qiu Yanjun (Jira)
• 2026/07/04 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting ASF GitHub Bot (Jira)
• 2026/07/04 [PR] [FLINK-39613][runtime] Unquote schema metadata keys [flink-cdc] via GitHub
• 2026/07/04 [jira] [Commented] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml Qiu Yanjun (Jira)
• 2026/07/04 [jira] [Updated] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml ASF GitHub Bot (Jira)
• 2026/07/04 [PR] [FLINK-40051][pipeline-connector/hudi] Fix schema operator UID with operator UID prefix [flink-cdc] via GitHub
• 2026/07/04 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/04 [jira] [Commented] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml Qiu Yanjun (Jira)
• 2026/07/04 [jira] [Commented] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting Qiu Yanjun (Jira)
• 2026/07/04 [jira] [Commented] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Qiu Yanjun (Jira)
• 2026/07/04 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [BP-2.2][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40069][tests] Stabilize OpenTelemetryMetricReporterProtocolTest against collector startup race [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40069][tests] Stabilize OpenTelemetryMetricReporterProtocolTest against collector startup race [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39954][tests] Relax SinkV2 scaling commit assertion [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40072][connector-http] Read request.timeout as the declared Duration option [flink-connector-http] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40072][connector-http] Read request.timeout as the declared Duration option [flink-connector-http] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40072][connector-http] Read request.timeout as the declared Duration option [flink-connector-http] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40072][connector-http] Read request.timeout as the declared Duration option [flink-connector-http] via GitHub
• 2026/07/04 [jira] [Updated] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value ASF GitHub Bot (Jira)
• 2026/07/04 [PR] [FLINK-40072][connector-http] Read request.timeout as the declared Duration option [flink-connector-http] via GitHub
• 2026/07/04 [jira] [Updated] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value Bharath Reddy Gunapati (Jira)
• 2026/07/04 [jira] [Created] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value Bharath Reddy Gunapati (Jira)
• 2026/07/04 Re: [PR] [BP-2.2][FLINK-38441][FLINK-39182][tests] Fix flaky ExecutionGraph restart tests under async TDD creation [flink] via GitHub
• 2026/07/04 Re: [PR] [BP-2.2][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/04 Re: [PR] [BP-2.3][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/04 [PR] [BP-2.2][FLINK-38441][FLINK-39182][tests] Fix flaky ExecutionGraph restart tests under async TDD creation [flink] via GitHub
• 2026/07/04 [PR] [BP-2.2][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/04 [PR] [BP-2.3][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/04 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/04 [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/04 [jira] [Updated] (FLINK-40019) FLIP-588: Support per-job delegation tokens ASF GitHub Bot (Jira)
• 2026/07/04 Re: [PR] [FLINK-38449][core] Reject fractional MemorySize values with explicit error [flink] via GitHub
• 2026/07/04 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39934][postgres] Fix invalid tables format error message [flink-cdc] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/04 Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• 2026/07/04 Re: [I] [Feature] Track token usage metrics for embedding models [flink-agents] via GitHub
• 2026/07/04 [PR] [api][python][java] Track embedding token usage metrics [flink-agents] via GitHub
• 2026/07/04 [jira] [Resolved] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink Martijn Visser (Jira)
• 2026/07/04 Re: [PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39674][formats] Upgrade Confluent Schema Registry client [flink] via GitHub
• 2026/07/04 [jira] [Resolved] (FLINK-40053) Log4j 2.26.1 bump Martijn Visser (Jira)
• 2026/07/04 Re: [PR] [FLINK-39674][formats] Upgrade Confluent Schema Registry client [flink] via GitHub
• 2026/07/04 [jira] [Updated] (FLINK-40053) Log4j 2.26.1 bump ASF GitHub Bot (Jira)
• 2026/07/04 Re: [PR] [FLINK-40053] Update Log4j to 2.26.1 [flink] via GitHub
• 2026/07/04 Re: [PR] [FLINK-39633][postgres] Fix NPE in incremental snapshot backfill when WAL carries records for other captured tables [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39969] [runtime] Apply configured SSL protocols and algorithms [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39587][runtime-web] Remove eslint cache from web dashboard lint [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39969] [runtime] Apply configured SSL protocols and algorithms [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40071) Bump jackson-bom to 2.21.4+ Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40071) Bump jackson-bom to 2.21.4+ Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40071) Bump jackson-bom to 2.21.4+ Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40071) Bump jackson-bom to 2.21.4+ Purushottam Sinha (Jira)
• 2026/07/03 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/03 [jira] [Closed] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Peter Huang (Jira)
• 2026/07/03 [jira] [Commented] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Peter Huang (Jira)
• 2026/07/03 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/03 [jira] [Assigned] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Peter Huang (Jira)
• 2026/07/03 Re: [PR] [FLINK-36298][table] Fix NullPointerException in metadata query supplier on fresh threads [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39633][postgres] Fix NPE in incremental snapshot backfill when WAL carries records for other captured tables [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• 2026/07/03 Re: [I] [Feature] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/03 Re: [I] [Bug] Python AgentConfigOptions starts PyFlink gateway during Pemja worker initialization [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40071) Bump jackson-bom to 2.21.4 Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40071) Bump jackson-bom to 2.21.4 ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40071) Bump jackson-bom to 2.21.4 Purushottam Sinha (Jira)
• 2026/07/03 Re: [PR] [common] Add PatternCache to optimize regex compilation performance [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39213][paimon] Filter out empty CommitMessageImpl to avoid unnecessary commit operations. [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [common] Add PatternCache to optimize regex compilation performance [flink-cdc] via GitHub
• 2026/07/03 [PR] [FLINK-40068][tests] Do not assert apply() was called when cancelling KeyedJob window [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race ASF GitHub Bot (Jira)
• 2026/07/03 Re: [PR] [FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40069][tests] Stabilize OpenTelemetryMetricReporterProtocolTest against collector startup race [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40068][tests] Do not assert apply() was called when cancelling KeyedJob window [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40067][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByJobFinished [flink] via GitHub
• 2026/07/03 [PR] [FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish ASF GitHub Bot (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file ASF GitHub Bot (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40069][tests] Stabilize OpenTelemetryMetricReporterProtocolTest against collector startup race [flink] via GitHub
• 2026/07/03 [PR] [FLINK-40067][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByJobFinished [flink] via GitHub
• 2026/07/03 [jira] [Resolved] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it Martijn Visser (Jira)
• 2026/07/03 Re: [PR] [FLINK-40064][python][e2e] Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish Martijn Visser (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40032) Migrate web-dashboard eslint to v9 (flat config) ASF GitHub Bot (Jira)
• 2026/07/03 Re: [PR] [FLINK-40032][runtime-web] Migrate web-dashboard eslint to v9 (flat config) [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/03 [jira] [Commented] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Resolved] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Matthias Pohl (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Matthias Pohl (Jira)
• 2026/07/03 [jira] [Comment Edited] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Matthias Pohl (Jira)
• 2026/07/03 Re: [PR] [BP-1.20][FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-2.2][FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-2.3][FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/07/03 [jira] [Resolved] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents Martijn Visser (Jira)
• 2026/07/03 Re: [PR] [BP-2.3][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-2.2][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-1.20][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-2.3][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-2.2][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 Re: [PR] [BP-1.20][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 [PR] [BP-2.3][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 [PR] [BP-2.2][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 [PR] [BP-1.20][FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 Purushottam Sinha (Jira)
• 2026/07/03 Re: [PR] [FLINK-40065][Connectors/AWS] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-aws] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40065][Connectors/AWS] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-aws] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40065][Connectors/AWS] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-aws] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Purushottam Sinha (Jira)
• 2026/07/03 Re: [PR] Fix MySQL CDC column comment propagation and complete schema change/comment PR [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40064][python][e2e] Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40064][python][e2e] Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40064][python][e2e] Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink [flink] via GitHub
• 2026/07/03 [jira] [Commented] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it Martijn Visser (Jira)
• 2026/07/03 Re: [PR] [FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40064][python][e2e] Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it Martijn Visser (Jira)
• 2026/07/03 [jira] [Commented] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it Martijn Visser (Jira)
• 2026/07/03 Re: [PR] [FLINK-40060][Connectors/JDBC] Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility [flink-connector-jdbc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it Martijn Visser (Jira)
• 2026/07/03 [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/03 [I] [Bug] [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/03 [jira] [Commented] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Roman Khachatryan (Jira)
• 2026/07/03 [jira] [Resolved] (FLINK-39916) Incorrect placeholder used in MySqlDataSourceFactory exception message Yanquan Lv (Jira)
• 2026/07/03 Re: [PR] [FLINK-39916][mysql] Fix MySQL batch startup option validation error [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40060] Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility [flink-connector-jdbc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40063) Tests: migrate JUnit 5 (Jupiter) to JUnit 6 Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml ASF GitHub Bot (Jira)
• 2026/07/03 [jira] [Commented] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40060] Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility [flink-connector-jdbc] via GitHub
• 2026/07/03 [PR] [FLINK-40061] Update parent version and flink.version in flink-connector-jdbc pom.xml [flink-connector-jdbc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml ChanBin OH (Jira)
• 2026/07/03 [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/07/03 [jira] [Commented] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Gyula Fora (Jira)
• 2026/07/03 [jira] [Commented] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Lucas Borges (Jira)
• 2026/07/03 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub

• Earlier messages