issues  

Messages by Date

• 2026/11/02 [jira] [Updated] (FLINK-41298) Document and test that JSON input is read only up to its first value Ramin Gharib (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40886][runtime] Do not create the application directory in the final cleanup check [flink] robinrvm (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream` Yuepeng Pan (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-2.3][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink] robinrvm (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via issues
• 2026/11/02 [PR] [FLINK-41304] Support canary resources on FlinkDeployment only [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] dataengineervishal (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-40843) Add StateCatalog documentation Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-40438) Add DataFrame inspection and rich display APIs Yuepeng Pan (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-39367][connector-http] Add configurable error logging with detailed context [flink-connector-http] bharathgunapati (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table [flink] flinkbot (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Rui Fan (Jira) via issues
• 2026/11/02 [jira] [Resolved] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira) via issues
• 2026/11/02 [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] raminqaf (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable Rui Fan (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Sumaiya Azad (Jira) via issues
• 2026/11/02 [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] raminqaf (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Rui Fan (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41298) PARSE_JSON, TRY_PARSE_JSON and the raw format drop content after the first JSON value ASF GitHub Bot (Jira) via issues
• 2026/11/02 [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table [flink] spuru9 (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40123][e2e] check_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink] mbarnacki (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 [jira] [Created] (FLINK-41309) Expose the JobManager deployment status and the resource age as kubectl printer columns Dennis-Mircea Ciupitu (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] hanyuzheng7 (via GitHub) via issues
• 2026/11/02 [jira] [Created] (FLINK-41308) Web dashboard: TaskManager Metrics "Netty Shuffle Buffers" Available/Total are always blank Purushottam Sinha (Jira) via issues
• 2026/11/02 Re: [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41304) Support canary resources on FlinkDeployment only ASF GitHub Bot (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-2.4][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41305][table-runtime] Require UTF-8 for a VARIANT column in the raw format and parse it from bytes [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
• 2026/11/02 [jira] [Assigned] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Hao Li (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes ASF GitHub Bot (Jira) via issues
• 2026/11/02 Re: [PR] [BP-2.3][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
• 2026/11/02 [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] dataengineervishal (via GitHub) via issues
• 2026/11/02 [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [hotfix][ci] Do not run npm test/lint for compile_ci, use Redhat only for certain groups [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] agresch (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] flinkbot (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41304) Support canary resources on FlinkDeployment only Dennis-Mircea Ciupitu (Jira) via issues
• 2026/11/02 [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 [jira] [Created] (FLINK-41304) Support canary resources on FlinkDeployment only Dennis-Mircea Ciupitu (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39386] For Flink 2.x+, support limit the rate at the source [flink-cdc] sd4324530 (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-2.4][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector [flink] gaborgsomogyi (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector [flink] gaborgsomogyi (via GitHub) via issues
• 2026/11/02 [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40954] Force delete pods stuck Terminating on cluster resourcecleanup timeout [flink-kubernetes-operator] gyfora (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 [jira] [Comment Edited] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] FLINK-31737: Hide rescale buttons for batch jobs in WebUI [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40123][e2e] check_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink] mbarnacki (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-2.3][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] twalthr (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-1.20][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] RocMarshal (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 [jira] [Created] (FLINK-41302) Expose canary reconcile latency as a measure of reconciliation pool saturation Dennis-Mircea Ciupitu (Jira) via issues
• 2026/11/02 Re: [PR] [BP-1.20][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] flinkbot (via GitHub) via issues
• 2026/11/02 [PR] [BP-3.7][FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40843) Add StateCatalog documentation Gyula Fora (Jira) via issues
• 2026/11/02 [jira] [Assigned] (FLINK-40843) Add StateCatalog documentation Gyula Fora (Jira) via issues
• 2026/11/02 [PR] [BP-1.20][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] flinkbot (via GitHub) via issues
• 2026/11/02 [PR] [BP-2.3][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 Re: [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.7 to 1.1.10.9 [flink] dependabot[bot] (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context Timo Walther (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context Yuepeng Pan (Jira) via issues
• 2026/11/02 Re: [PR] [BP-2.2][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] twalthr (via GitHub) via issues
• 2026/11/02 [jira] [Comment Edited] (FLINK-40843) Add StateCatalog documentation Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40843) Add StateCatalog documentation Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40438) Add DataFrame inspection and rich display APIs Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-39258) FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Created] (FLINK-41301) Throw TableRuntimeException for every failed cast from VARIANT Ramin Gharib (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] flinkbot (via GitHub) via issues
• 2026/11/02 Re: [PR] [runtime] Add cross-release state migration test for ActionExecutionOperator [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41299) Watermark alignment deadlocks checkpoints after source subtasks finish Chen Zhang (Jira) via issues
• 2026/11/02 Re: [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Robin Varghese (Jira) via issues
• 2026/11/02 Re: [PR] [BP-2.4][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink] robinrvm (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41253][python] Preserve scalar projection order when using async UDFs [flink] bgeng777 (via GitHub) via issues
• 2026/11/02 [PR] [BP-2.3][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink] robinrvm (via GitHub) via issues
• 2026/11/02 [PR] [BP-2.4][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink] robinrvm (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] Myracle (via GitHub) via issues
• 2026/11/02 Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/02 [jira] [Assigned] (FLINK-41298) PARSE_JSON, TRY_PARSE_JSON and the raw format drop content after the first JSON value Ramin Gharib (Jira) via issues
• 2026/11/02 Re: [PR] [BP-3.7][FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] yuxiqian (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] pnowojski (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Resolved] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Dian Fu (Jira) via issues
• 2026/11/01 Re: [D] Human-in-the-loop approval: pluggable approver (decision model first, human fallback) - design discussion for #1067 [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/01 [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 Re: [PR] [docs][release-0.4] Standardize Alibaba Cloud Model Studio naming [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/01 Re: [PR] [hotfix][api][java] Move ResourceContext lookup factory to test utilities [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] flinkbot (via GitHub) via issues
• 2026/11/01 Re: [PR] [python] Read flat agent.* keys from configuration files [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] flinkbot (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] flinkbot (via GitHub) via issues
• 2026/11/01 [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-39386] For Flink 2.x+, support limit the rate at the source [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache [flink] dianfu (via GitHub) via issues
• 2026/11/01 [PR] [api][plan][runtime][java] Unify Future scheduling and tool execution [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-39700) Fix name-based column matching in materialized table schema diff Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Resolved] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events Yanquan Lv (Jira) via issues
• 2026/11/01 Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/01 [jira] [Commented] (FLINK-40185) Introduce DataFrame API in PyFlink Dian Fu (Jira) via issues
• 2026/11/01 [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Rui Fan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-37593) Add Some Reduce Expression Rules Yuepeng Pan (Jira) via issues
• 2026/11/01 Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink] snuyanzin (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] flinkbot (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yuepeng Pan (Jira) via issues
• 2026/11/01 Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] flinkbot (via GitHub) via issues
• 2026/11/01 [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] flinkbot (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36160) Support hive advanced configuration Yuepeng Pan (Jira) via issues
• 2026/11/01 Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] flinkbot (via GitHub) via issues
• 2026/11/01 [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation Rui Fan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Created] (FLINK-41294) PyFlink batch: pandas UDAF over a RANGE frame with CURRENT ROW or n PRECEDING / FOLLOWING reads the ORDER BY key as TIMESTAMP(3) and gets wrong frames for INT and DECIMAL keys Yaoxuan Wu (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-39544) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Commented] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution Rui Fan (Jira) via issues
• 2026/11/01 Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] flinkbot (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] flinkbot (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36363) Remove references to scala-relate api in tests among table modules Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-41291) Bump snappy-java to 1.1.10.12 ASF GitHub Bot (Jira) via issues
• 2026/11/01 [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira) via issues
• 2026/11/01 [PR] [BP-2.3][FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink] 1996fanrui (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] fresh-borzoni (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] fresh-borzoni (via GitHub) via issues
• 2026/11/01 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] fresh-borzoni (via GitHub) via issues
• 2026/11/01 [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.4 to 1.1.10.9 [flink-connector-prometheus] dependabot[bot] (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Resolved] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e Sergey Nuyanzin (Jira) via issues
• 2026/11/01 [jira] [Commented] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e Sergey Nuyanzin (Jira) via issues
• 2026/11/01 Re: [PR] [FLINK-41275][e2e] Start containers in e2e per class rather than per test in SQL e2e [flink] snuyanzin (via GitHub) via issues
• 2026/11/01 [jira] [Commented] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Reopened] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Created] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API Yuepeng Pan (Jira) via issues
• 2026/11/01 [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.5 to 1.1.10.9 [flink-connector-opensearch] dependabot[bot] (via GitHub) via issues
• 2026/11/01 [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.4 to 1.1.10.9 [flink-connector-pulsar] dependabot[bot] (via GitHub) via issues
• 2026/11/01 [PR] [LINK-41289] Run canary health checks only with the health probe enabled, on one named thread [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
• 2026/11/01 [jira] [Created] (FLINK-41289) Run canary health checks only with the health probe enabled, on one named thread Dennis-Mircea Ciupitu (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-41288) Recreating a canary resource leaves duplicate health check loops running ASF GitHub Bot (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view Purushottam Sinha (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40557) Make operation column optional in TO_CHANGELOG output Yuepeng Pan (Jira) via issues
• 2026/11/01 Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] pranavshuklaa (via GitHub) via issues
• 2026/11/01 [jira] [Updated] (FLINK-41129) [release-2.4] Add release notes Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0 Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-39545) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira) via issues
• 2026/11/01 [jira] [Updated] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView` Yuepeng Pan (Jira) via issues

• Later messages