issues  

Messages by Date

• 2026/07/06 [jira] [Updated] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based) ASF GitHub Bot (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes ASF GitHub Bot (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name Yuepeng Pan (Jira)
• 2026/07/06 [PR] [FLINK-39523] Checkpoint coordination during recovery (memory-based trigger) [flink] via GitHub
• 2026/07/06 [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc Yuepeng Pan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces Yuepeng Pan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue Yuepeng Pan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-40041) Update JDBC connector version to 3.4.0 Yuepeng Pan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-38616) Jdbc Catalog supports jdbc properties. Yuepeng Pan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-40042) Update JDBC connector version to 4.1.0 Yuepeng Pan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/06 [jira] [Commented] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/06 Re: [PR] [BP-2.3][FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-1.20][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.2][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] test: cover checkpoint coordinator scheduling [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-1.20][FLINK-36242][table] Fix unstable MaterializedTableStatementITCase [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40030][connector-http] Add architecture tests [flink-connector-http] via GitHub
• 2026/07/06 Re: [PR] [BP-1.20][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-36242) Fix unstable test in MaterializedTableITCase Martijn Visser (Jira)
• 2026/07/06 Re: [PR] [FLINK-39959] Improve the autoscaler context structure and propagation [flink-kubernetes-operator] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
• 2026/07/06 [PR] [BP-1.20][FLINK-36242][table] Fix unstable MaterializedTableStatementITCase [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40015) Wrap atomic PTF output in Row partition-key prepend & rowtime append in PTF Test Harness ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.3][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [BP-2.2][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/06 [PR] [BP-2.3][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 [PR] [BP-2.2][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40073] [INFRA] Add delete and force push protection to default and release branches [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [BP-1.20][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-34368][fs] Update GCS connector to 3.1.18 [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Piotr Nowojski (Jira)
• 2026/07/06 [jira] [Closed] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Piotr Nowojski (Jira)
• 2026/07/06 Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39680][FLINK-21378] Supports unaligned checkpoint on pointwise edges [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40037][tests] Local RocksDB working directory leaked (with all… [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-39521) Support push-based recovery in input channels ASF GitHub Bot (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo) ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
• 2026/07/06 [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
• 2026/07/06 [jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints Rui Fan (Jira)
• 2026/07/06 [jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39524) Introduce the fetched-channel-state spill subsystem (segmented spill files, filtered write, reader) Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39524) Introduce the fetched-channel-state spill subsystem (segmented spill files, filtered write, reader) Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based) Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based) Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39521) Support push-based recovery in input channels Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39521) Support push-based recovery in input channels Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes Rui Fan (Jira)
• 2026/07/06 Re: [I] [Bug] ActionStateSerde: nested byte[] (and Long→Integer) type-loss in MemoryUpdate container values on durable replay [flink-agents] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo) Rui Fan (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo) Rui Fan (Jira)
• 2026/07/06 [jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths Fabian Hueske (Jira)
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/06 Re: [I] [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase. [flink-agents] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Filippo Ghibellini (Jira)
• 2026/07/06 [jira] [Commented] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x Taranpreet Kaur (Jira)
• 2026/07/06 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.3][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-1.20][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.2][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40049] [Connectors / Prometheus] compatibility changes for Flink-connector-Prometheus for … [flink-connector-prometheus] via GitHub
• 2026/07/06 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-40049] [Connectors / Prometheus] compatibility changes for Flink-connector-Prometheus for … [flink-connector-prometheus] via GitHub
• 2026/07/06 [PR] [BP-2.2][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 [PR] [BP-1.20][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [api][plan][python] Use request-scoped metric groups for chat token metrics [flink-agents] via GitHub
• 2026/07/06 [PR] [BP-2.3][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] via GitHub
• 2026/07/06 [jira] [Assigned] (FLINK-40045) Upgrade d3-flame-graph to v5 Martijn Visser (Jira)
• 2026/07/06 [jira] [Updated] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Piotr Nowojski (Jira)
• 2026/07/06 [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Piotr Nowojski (Jira)
• 2026/07/06 Re: [PR] [FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/06 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/06 [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/06 Re: [PR] [BP-2.3][FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/06 [PR] [BP-2.3][FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/06 [jira] [Commented] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/06 [jira] [Resolved] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/06 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause Martijn Visser (Jira)
• 2026/07/06 [jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause Martijn Visser (Jira)
• 2026/07/06 Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40077][table-planner] Fix lost NoMoreSplitsEvent masking failure cause in CommonExecSinkITCase [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-40077][table-planner] Fix lost NoMoreSplitsEvent masking failure cause in CommonExecSinkITCase [flink] via GitHub
• 2026/07/06 [jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause Martijn Visser (Jira)
• 2026/07/06 Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
• 2026/07/06 [jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Martijn Visser (Jira)
• 2026/07/06 Re: [PR] [FLINK-39959] Improve the autoscaler context structure and propagation [flink-kubernetes-operator] via GitHub
• 2026/07/06 [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/06 Re: [I] [Feature] [integration] [java] Integrate built-in Google Gemini chat model [flink-agents] via GitHub
• 2026/07/06 Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
• 2026/07/06 Re: [I] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/07/05 Re: [I] [python] Verify and admit `bytes` in the Python memory value contract [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [Feature][Java] Move MCP resource discovery to runtime [flink-agents] via GitHub
• 2026/07/05 Re: [I] [Bug] ActionStateSerde: nested byte[] (and Long→Integer) type-loss in MemoryUpdate container values on durable replay [flink-agents] via GitHub
• 2026/07/05 Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
• 2026/07/05 Re: [I] [Bug] ActionStateSerde: nested byte[] (and Long→Integer) type-loss in MemoryUpdate container values on durable replay [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40056][docs] Support configuration anchor navigation in PyFlink [flink] via GitHub
• 2026/07/05 [jira] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED Mao Jiayi (Jira)
• 2026/07/05 Re: [PR] [FLINK-39669][table-planner] BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan [flink] via GitHub
• 2026/07/05 Re: [PR] [dist] Add Flink 2.3 distribution and make it the default [flink-agents] via GitHub
• 2026/07/05 [jira] [Resolved] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism Yanquan Lv (Jira)
• 2026/07/05 [jira] [Commented] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED Mao Jiayi (Jira)
• 2026/07/05 [jira] [Resolved] (FLINK-39934) Postgres pipeline connector reports misleading table format error message Yanquan Lv (Jira)
• 2026/07/05 Re: [PR] [FLINK-40043] fix the paimon pipeline job couldn’t increase job parallelism. [flink-cdc] via GitHub
• 2026/07/05 Re: [PR] [FLINK-39934][postgres] Fix invalid tables format error message [flink-cdc] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40073] [INFRA] Add delete and force push protection to default and release branches [flink] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40073] [INFRA] Add delete and force push protection to default and release branches [flink] via GitHub
• 2026/07/05 Re: [PR] [test][build] Try to fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/05 Re: [PR] [test][build] Try to fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/05 [jira] [Created] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
• 2026/07/05 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/05 Re: [I] [Bug] ActionStateSerde: nested byte[] (and Long→Integer) type-loss in MemoryUpdate container values on durable replay [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [FLINK-39034][runtime] Preserve timestamps in SortPartitionOperator [flink] via GitHub
• 2026/07/05 [PR] [FLINK-39034][runtime] Preserve timestamps in SortPartitionOperator [flink] via GitHub
• 2026/07/05 Re: [PR] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/05 Re: [I] [Bug] byte[] memory values corrupted to base64 String on the durable-execution replay path [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/05 [jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 [jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect [flink-cdc] via GitHub
• 2026/07/05 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 Re: [PR] [FLINK-40051][pipeline-connector/hudi] Fix schema operator UID with operator UID prefix [flink-cdc] via GitHub
• 2026/07/05 [jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Robert Yokota (Jira)
• 2026/07/05 [jira] [Created] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) Martijn Visser (Jira)
• 2026/07/05 [jira] [Commented] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• 2026/07/05 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/05 [jira] [Commented] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart Zakelly Lan (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart ASF GitHub Bot (Jira)
• 2026/07/05 Re: [PR] [FLINK-40037][tests] Local RocksDB working directory leaked (with all… [flink] via GitHub
• 2026/07/05 [jira] [Updated] (FLINK-38732) Enable the stale bot for the JDBC connector Yuepeng Pan (Jira)
• 2026/07/05 [jira] [Closed] (FLINK-40041) Update JDBC connector version to 3.4.0 Yuepeng Pan (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-39972) Release flink-connector-jdbc v3.4.0 for Flink 1.20 Yuepeng Pan (Jira)
• 2026/07/05 [jira] [Closed] (FLINK-40042) Update JDBC connector version to 4.1.0 Yuepeng Pan (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-39960) Remove broken JavaDoc shortcode usage from JDBC datastream docs Yuepeng Pan (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-38733) Allow more dynamic splitter on JdbcSource Yuepeng Pan (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-34467) Implement Lineage Interface in Jdbc Connector Yuepeng Pan (Jira)
• 2026/07/05 Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• 2026/07/05 Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• 2026/07/05 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/07/05 Re: [PR] [test] Try to Fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/07/05 Re: [PR] [FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/05 Re: [PR] [FLINK-40073] [INFRA] Add delete and force push protection to default and release branches [flink] via GitHub
• 2026/07/05 [jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/07/05 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `VARIANT_QUERY` to extract values from a variant Jinkun Liu (Jira)
• 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)

• Earlier messages
• Later messages