issues  

Messages by Date

• 2026/11/03 [jira] [Updated] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira) via issues
• 2026/11/03 Re: [I] [Feature][api] Propagate user-defined context from request events to response events [flink-agents] eemario (via GitHub) via issues
• 2026/11/03 Re: [PR] [BP-2.4][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] flinkbot (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] flinkbot (via GitHub) via issues
• 2026/11/03 [jira] [Assigned] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1) Samrat Deb (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40812) [Backport][1.20] Backport FLINK-38558 to release-1.20 Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-38392) StreamPandasConversionTests failing Yuepeng Pan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 [jira] [Resolved] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] Biasqo (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name Yuepeng Pan (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format Ramin Gharib (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40812][state] Backport FLINK-38558 to release-1.20 [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [jira] [Created] (FLINK-41316) Publish built-in function pages as Markdown with an llms.txt index Ramin Gharib (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc] yuxiqian (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Ramin Gharib (Jira) via issues
• 2026/11/03 Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] semlanghi (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [PR] [FLINK-35335][network] Hold back priority buffers on subpartitions blocked by aligned barriers [flink] spuru9 (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [runtime] Fix action-state key collisions between event occurrences with identical attributes [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e Sergey Nuyanzin (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 Re: [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents] purushah (via GitHub) via issues
• 2026/11/03 Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] semlanghi (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41321) A join on an ARRAY<MAP> key returns no rows, although the same two maps compare equal with = sepuri sai krishna (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view Purushottam Sinha (Jira) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.3) [flink] gustavodemorais (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41318) ASCII returns a negative number for characters outside US-ASCII sepuri sai krishna (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin [flink] bvarghese1 (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink] raminqaf (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Purushottam Sinha (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41315) Add the page structure for built-in function docs Ramin Gharib (Jira) via issues
• 2026/11/03 Re: [D] Human-in-the-loop approval: pluggable approver (decision model first, human fallback) - design discussion for #1067 [flink-agents] Ashfaqbs (via GitHub) via issues
• 2026/11/03 Re: [PR] [runtime] Fix action-state key collisions between event occurrences with identical attributes [flink-agents] Ashfaqbs (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 [PR] [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector [flink] Samrat002 (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41303][runtime-web] Only send job submission parameters in the request body [flink] leosanqing (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code ASF GitHub Bot (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector [flink] Samrat002 (via GitHub) via issues
• 2026/11/03 [jira] [Closed] (FLINK-41014) Add an adaptive retry mode to the native S3 connector Samrat Deb (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector [flink] gaborgsomogyi (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41317][pipeline-connector/kafka] Fix NPE when serializing REPLACE events without before image [flink-cdc] dev-donghwan (via GitHub) via issues
• 2026/11/03 Re: [PR] [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] flinkbot (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] vsantwana (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] raminqaf (via GitHub) via issues
• 2026/11/03 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/03 [PR] [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
• 2026/11/03 Re: [PR] [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
• 2026/11/03 [jira] [Created] (FLINK-41325) COMPILE PLAN emits no state array for a temporal join or MATCH_RECOGNIZE, so their TTL cannot be configured as documented sepuri sai krishna (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41324) COLLECT returns extra multiset entries when mini-batch is enabled, and the result varies between runs sepuri sai krishna (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41324) COLLECT returns extra multiset entries when mini-batch is enabled, and the result varies between runs sepuri sai krishna (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira) via issues
• 2026/11/03 [jira] [Closed] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1) Samrat Deb (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41317) [pipeline-connector/kafka] NullPointerException when serializing REPLACE events in canal-json and debezium-json kim (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41322) JSON_QUOTE does not round-trip a character outside the BMP through JSON_UNQUOTE sepuri sai krishna (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
• 2026/11/03 [jira] [Created] (FLINK-41320) CAST of ARRAY, ROW or MAP to CHAR/VARCHAR(n) returns fewer than n characters and can insert a '?' sepuri sai krishna (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41319) REGEXP_INSTR disagrees with POSITION, LOCATE and INSTR for characters outside the BMP sepuri sai krishna (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41318) ASCII returns a negative number for characters outside US-ASCII sepuri sai krishna (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink] Timm0 (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink] Timm0 (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink] Timm0 (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws ASF GitHub Bot (Jira) via issues
• 2026/11/03 [PR] [FLINK-41069] Support for Flink 2.2.1 [flink-connector-aws] junmuz (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41069] Support for Flink 2.2.1 [flink-connector-aws] boring-cyborg[bot] (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41064) 'State TTL Heap backend end-to-end test' fails on a "Trying to access closed classloader" log4j error in the TaskManager .out files Purushottam Sinha (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-35335][network] Hold back priority buffers on subpartitions blocked by aligned barriers [flink] flinkbot (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] Biasqo (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-39192) SinkWriterOperator in post-commit topology throws IllegalStateException with bounded source in streaming mode Purushottam Sinha (Jira) via issues
• 2026/11/03 [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] Biasqo (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] Biasqo (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] Biasqo (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira) via issues
• 2026/11/03 [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.4 to 1.1.10.9 [flink-connector-cassandra] dependabot[bot] (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] Biasqo (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41303) Web UI job submission fails with long program arguments ASF GitHub Bot (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] raminqaf (via GitHub) via issues
• 2026/11/03 [jira] [Resolved] (FLINK-41298) Document and test that JSON input is read only up to its first value Ramin Gharib (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41298][table] Document and test that JSON input is read only up to its first value [flink] raminqaf (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [I] [Feature][api] Propagate user-defined context from request events to response events [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41317][pipeline-connector/kafka] Fix NPE when serializing REPLACE events without before image [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/03 [PR] [FLINK-41317][pipeline-connector/kafka] Fix NPE when serializing REPLACE events without before image [flink-cdc] dev-donghwan (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41107][pipeline-connector] Honor accepted schema evolution types in Hudi and MaxCompute sinks [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] snuyanzin (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] snuyanzin (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc] fe80 (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41312) Fluss pipeline source does not retire dropped or expired partitions while running liting liu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-39109) [Phase 2] Native s3 Filesystem Yuepeng Pan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41312) Fluss pipeline source does not retire dropped or expired partitions while running ASF GitHub Bot (Jira) via issues
• 2026/11/03 [PR] [FLINK-41312][pipeline-connector/fluss] Retire dropped or expired partitions while running [flink-cdc] litiliu (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Rui Fan (Jira) via issues
• 2026/11/02 [jira] (FLINK-41312) Fluss pipeline source does not retire dropped or expired partitions while running liting liu (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• 2026/11/02 [jira] [Reopened] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) 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] lvyanquan (via GitHub) via issues
• 2026/11/02 Re: [PR] [BP-2.4][FLINK-41275][e2e] Start SQL e2e test clusters once per class instead of per test [flink] flinkbot (via GitHub) via issues
• 2026/11/02 [PR] [BP-2.4][FLINK-41275][e2e] Start SQL e2e test clusters once per class instead of per test [flink] snuyanzin (via GitHub) 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] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions ASF GitHub Bot (Jira) via issues
• 2026/11/02 [PR] [FLINK-41313][pipeline-connector/fluss] Fix checkpoint recovery after partition removal [flink-cdc] litiliu (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41313) Fluss pipeline source does not unsubscribe dropped or expired partitions liting liu (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE Xiqian Yu (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Naveen Joseph (Jira) via issues
• 2026/11/02 [jira] [Comment Edited] (FLINK-41290) PyFlink streaming: Python UDTF in a lateral join loses the row kind of the input (NULL-padded LEFT JOIN rows; every row in thread mode) Sangkyoon Nam (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-40301][table] Merge Calc nodes before ChangelogNormalize projection pushdown [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-38489][table] Avoid unnecessary DELETE inference for ChangelogNormalize [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-35324][formats] Avro format can not perform projection pushdown for specific fields [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-40320][ci] Exclude author and co-author reviews from community review labeling [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/02 Re: [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents] sangkyoonnam (via GitHub) via issues
• 2026/11/02 [jira] [Closed] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-40501][datastream] Keep watermark status ordered with queued watermarks in AsyncWaitOperator [flink] kotwal-itpro (via GitHub) via issues
• 2026/11/02 Re: [PR] [python] Read flat agent.* keys from configuration files [flink-agents] sharpca (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] poorbarcode (via GitHub) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via issues
• 2026/11/02 [jira] [Assigned] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE Xiqian Yu (Jira) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] poorbarcode (via GitHub) via issues
• 2026/11/02 [jira] [Created] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] Copilot (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] gaborgsomogyi (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 [jira] [Closed] (FLINK-40221) Update weekly.yml of jdbc connector for jdbc-3.4.0 and jdbc-4.1.0 Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Closed] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Commented] (FLINK-41290) PyFlink streaming: Python UDTF in a lateral join loses the row kind of the input (NULL-padded LEFT JOIN rows; every row in thread mode) Sangkyoon Nam (Jira) via issues
• 2026/11/02 Re: [PR] [FLINK-41303][runtime-web] Only send job submission parameters in the request body [flink] flinkbot (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-37624) Support enableAsyncState and switch operator after datastream transformation Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Created] (FLINK-41313) Fluss pipeline source does not unsubscribe dropped or expired partitions liting liu (Jira) via issues
• 2026/11/02 [PR] [FLINK-41303][runtime-web] Only send job submission parameters in the request body [flink] leosanqing (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-39386] For Flink 2.x+, support limit the rate at the source [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via issues
• 2026/11/02 [jira] [Created] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via issues
• 2026/11/02 [jira] [Created] (FLINK-41299) Watermark alignment deadlocks checkpoints after source subtasks finish Chen Zhang (Jira) via issues
• 2026/11/02 [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41253][python] Preserve scalar projection order when using async UDFs [flink] auroflow (via GitHub) via issues
• 2026/11/02 [jira] [Resolved] (FLINK-39700) Fix name-based column matching in materialized table schema diff Yuepeng Pan (Jira) via issues
• 2026/11/02 [jira] [Created] (FLINK-41303) Web UI job submission fails with long program arguments sanqingleo (Jira) via issues
• 2026/11/02 Re: [PR] [BP-2.1][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] twalthr (via GitHub) via issues
• 2026/11/02 [PR] [FLINK-41288] Recreating a canary resource leaves duplicate health check loops running [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
• 2026/11/02 [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. Yuepeng Pan (Jira) via issues
• 2026/11/02 [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 Re: [PR] [FLINK-41253][python] Preserve scalar projection order when using async UDFs [flink] auroflow (via GitHub) via issues
• 2026/11/02 Re: [PR] [FLINK-41253][python] Preserve scalar projection order when using async UDFs [flink] auroflow (via GitHub) via issues

• Earlier messages
• Later messages