issues  

Messages by Date

• 2026/07/07 [PR] [FLINK-40091] upgrade paimon to 1.4.2 [flink-cdc] via GitHub
• 2026/07/07 [jira] [Created] (FLINK-40091) upgrade paimon to 1.4.2 peiyu (Jira)
• 2026/07/07 Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-40090) Modernize cryptography export notice in distribution README ASF GitHub Bot (Jira)
• 2026/07/07 [PR] [FLINK-40090][docs] Add cryptography export notice to README [flink-shaded] via GitHub
• 2026/07/07 Re: [PR] Modernize cryptography export notice in distribution README [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40015] Introduce getRuntimeOutput in PTF Test Harness [flink] via GitHub
• 2026/07/07 [PR] Modernize cryptography export notice in distribution README [flink] via GitHub
• 2026/07/07 [jira] [Created] (FLINK-40090) Modernize cryptography export notice in distribution README Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [BP-1.20][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/07 [jira] [Resolved] (FLINK-40032) Migrate web-dashboard eslint to v9 (flat config) Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [FLINK-40032][runtime-web] Migrate web-dashboard eslint to v9 (flat config) [flink] via GitHub
• 2026/07/07 Re: [D] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/07 [jira] [Assigned] (FLINK-40032) Migrate web-dashboard eslint to v9 (flat config) Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/07 [PR] [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase [flink-agents] via GitHub
• 2026/07/07 Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
• 2026/07/07 [jira] [Created] (FLINK-40089) Add JSON_LENGTH function Gustavo de Morais (Jira)
• 2026/07/07 Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40032][runtime-web] Migrate web-dashboard eslint to v9 (flat config) [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40071][build] Bump jackson-bom to 2.21.4 [flink] via GitHub
• 2026/07/07 [jira] [Resolved] (FLINK-40045) Upgrade d3-flame-graph to v5 Martijn Visser (Jira)
• 2026/07/07 [jira] [Assigned] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) ASF GitHub Bot (Jira)
• 2026/07/07 [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] via GitHub
• 2026/07/07 [jira] [Created] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [FLINK-40079][table] Reject PTF calls with sys-args if they are disabled [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40079][table] Reject PTF calls with sys-args if they are disabled [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths ASF GitHub Bot (Jira)
• 2026/07/07 [PR] [FLINK-40079][table] Reject PTF calls with sys-args if they are disabled [flink] via GitHub
• 2026/07/07 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/07/07 [jira] [Assigned] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths Fabian Hueske (Jira)
• 2026/07/07 Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
• 2026/07/07 Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
• 2026/07/07 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/07 Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions [flink-cdc] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/07/07 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/07 Re: [PR] [api][runtime][python] Propagate metric groups to cross-language reso… [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39784][table] Forbid SNAPSHOT function outside LATERAL context [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-39784) Add translation rule to block usage of SNAPSHOT function outside of LATERAL context ASF GitHub Bot (Jira)
• 2026/07/07 [PR] [FLINK-39784][table] Forbid SNAPSHOT function outside LATERAL context [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/07/07 Re: [PR] [ci] Use maintained 'temurin' distribution for setup-java [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions [flink-cdc] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions [flink-cdc] via GitHub
• 2026/07/07 Re: [PR] [api][python][java] Track embedding token usage metrics [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [BP-2.2][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• 2026/07/07 Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [BP-2.3][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• 2026/07/07 Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
• 2026/07/07 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [api][plan][python] Use request-scoped metric groups for chat token metrics [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
• 2026/07/07 [PR] [BP-2.2][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• 2026/07/07 [PR] [BP-2.3][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40087][mysql] Fix MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) [flink-cdc] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join ASF GitHub Bot (Jira)
• 2026/07/07 [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
• 2026/07/07 Re: [I] [Bug] ActionStateSerde cannot deserialize built-in event subclasses during durable recovery [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/07 Re: [D] [Discussion] Memory Observation Capability Design [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/07/07 Re: [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/07 [jira] [Resolved] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
• 2026/07/07 Re: [PR] [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• 2026/07/07 [PR] [infra] Add AGENTS.md [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
• 2026/07/07 Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
• 2026/07/07 [I] [Feature] Add AGENTS.md [flink-agents] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
• 2026/07/07 [jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [FLINK-32695][e2e] Migrate SqlToolbox watermark push-down source to Source V2 [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) ASF GitHub Bot (Jira)
• 2026/07/07 [PR] [FLINK-40087][mysql] Fix MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) [flink-cdc] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect [flink-cdc] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• 2026/07/07 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• 2026/07/07 [jira] [Resolved] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• 2026/07/07 [jira] [Assigned] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Timo Walther (Jira)
• 2026/07/07 [jira] [Assigned] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Timo Walther (Jira)
• 2026/07/07 [jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• 2026/07/07 Re: [PR] [FLINK-40068][tests] Do not assert apply() was called when cancelling KeyedJob window [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core Martijn Visser (Jira)
• 2026/07/07 [jira] [Updated] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Martijn Visser (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Martijn Visser (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [BP-2.2][FLINK-38441][FLINK-39182][tests] Fix flaky ExecutionGraph restart tests under async TDD creation [flink] via GitHub
• 2026/07/07 [jira] [Commented] (FLINK-39921) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Martijn Visser (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-39929) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. Martijn Visser (Jira)
• 2026/07/07 [jira] [Updated] (FLINK-39929) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [BP-2.2][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/07 [jira] [Updated] (FLINK-39921) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Martijn Visser (Jira)
• 2026/07/07 Re: [PR] [BP-2.3][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/07 Re: [PR] [BP-2.3][FLINK-39921][FLINK-39929][tests] Fix flaky scheduler tests under async TDD creation [flink] via GitHub
• 2026/07/07 Re: [PR] [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/07 [jira] [Commented] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
• 2026/07/07 [jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
• 2026/07/07 [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Fred Teunissen (Jira)
• 2026/07/07 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/07 Re: [D] [Discussion] Memory Observation Capability Design [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
• 2026/07/06 [jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink reswqa (Jira)
• 2026/07/06 Re: [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
• 2026/07/06 [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
• 2026/07/06 Re: [PR] [FLINK-36334][tests] Enable Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module [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-40045][runtime-web] Upgrade d3-flame-graph to v5 [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.1][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.3][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [D] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39946][runtime] Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources [flink] via GitHub
• 2026/07/06 [PR] [hotfix] Bump Mockito for JDK 17 tests [flink-cdc] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 ASF GitHub Bot (Jira)
• 2026/07/06 Re: [PR] [FLINK-40083][tests] Launch the SeaweedFS S3 test backend via 'weed mini' and bump to 4.38 [flink] via GitHub
• 2026/07/06 Re: [D] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/07/06 Re: [D] [Discussion] Memory Oobservation Capability Design [flink-agents] via GitHub
• 2026/07/06 Re: [D] [Discussion]Memory Oobservation Capability Design [flink-agents] via GitHub
• 2026/07/06 [D] Memory Oobservation Capability Design [flink-agents] via GitHub
• 2026/07/06 [jira] [Assigned] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Xiqian Yu (Jira)
• 2026/07/06 [jira] [Commented] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Xiqian Yu (Jira)
• 2026/07/06 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40040][cdc-runtime] Wrap coordinator failure in SerializedThrowable across the RPC boundary [flink-cdc] via GitHub
• 2026/07/06 Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
• 2026/07/06 Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39946][runtime] Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 2026/07/06 [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/06 [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/06 Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 2026/07/06 Re: [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [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: [PR] [FLINK-39946][runtime] Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 2026/07/06 [jira] [Commented] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Weiqing Yang (Jira)
• 2026/07/06 [jira] [Commented] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Bowen Li (Jira)
• 2026/07/06 [jira] [Resolved] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Bowen Li (Jira)
• 2026/07/06 [jira] [Resolved] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Bowen Li (Jira)
• 2026/07/06 [jira] [Commented] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Bowen Li (Jira)
• 2026/07/06 Re: [PR] [FLINK-38919][docs] Document PyFlink per-cluster offsets [flink-connector-kafka] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-39981) Autoscaler cannot trigger source rebalance after active split removal on dynamic Kafka source ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• 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 Re: [PR] [runtime] Preserve byte[] MemoryUpdate values across durable-execution serde (#865) [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [runtime] Preserve byte[] MemoryUpdate values across durable-execution serde (#865) [flink-agents] via GitHub
• 2026/07/06 [PR] [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope [flink-agents] via GitHub
• 2026/07/06 Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
• 2026/07/06 [jira] [Resolved] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) Martijn Visser (Jira)
• 2026/07/06 [PR] [ci] Use maintained 'temurin' distribution for setup-java [flink-agents] 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 Re: [PR] [BP-2.2][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-1.20][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.1][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [PR] [BP-2.3][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 [PR] [BP-1.20][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 [PR] [BP-2.1][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 [PR] [BP-2.3][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
• 2026/07/06 [jira] [Updated] (FLINK-40084) maven-shade-plugin does not respect multi release jars ASF GitHub Bot (Jira)
• 2026/07/06 [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink] via GitHub
• 2026/07/06 [jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars Sergey Nuyanzin (Jira)
• 2026/07/06 Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
• 2026/07/06 Re: [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka] via GitHub
• 2026/07/06 Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub

• Earlier messages
• Later messages