issues  

Messages by Date

• 2026/11/06 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/06 [jira] [Resolved] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Sergey Nuyanzin (Jira) via issues
• 2026/11/06 [jira] [Updated] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira) via issues
• 2026/11/06 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] snuyanzin (via GitHub) via issues
• 2026/11/06 [jira] [Updated] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira) via issues
• 2026/11/06 Re: [PR] [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin [flink] snuyanzin (via GitHub) via issues
• 2026/11/06 [jira] [Updated] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira) via issues
• 2026/11/06 [jira] [Created] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira) via issues
• 2026/11/06 Re: [PR] [FLINK-41367][connector-jdbc] Test the SQL Server dialect on SQL Server 2025 and cover XA [flink-connector-jdbc] Copilot (via GitHub) via issues
• 2026/11/06 [jira] [Updated] (FLINK-41367) JDBC: Test SQL Server dialect on SQL Server 2025, not retired Azure SQL Edge; cover XA ASF GitHub Bot (Jira) via issues
• 2026/11/06 [jira] [Resolved] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira) via issues
• 2026/11/06 [jira] [Created] (FLINK-41367) JDBC: Test SQL Server dialect on SQL Server 2025, not retired Azure SQL Edge; cover XA Purushottam Sinha (Jira) via issues
• 2026/11/06 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/06 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/06 [jira] [Commented] (FLINK-41293) PyFlink batch: pandas UDAF over ROWS BETWEEN n PRECEDING AND k PRECEDING (k >= 2) aggregates rows outside the frame for the first rows of a partition Yahya Kisana (Jira) via issues
• 2026/11/05 Re: [I] [runtime][python] Support TaskManager reuse across Flink Agents jobs [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 Re: [PR] [hotfix][ci] Cancel superseded CI runs for the same PR [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 [PR] [hotfix][ci] Cancel superseded CI runs for the same PR [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] ferenc-csaky (via GitHub) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-41357) FLIP-608: Flink on Ray — Ray Resource Backend For Flink Dian Fu (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41108][python] Use the TTL config when invalidating cached state after namespace merges [flink] dianfu (via GitHub) via issues
• 2026/11/05 [PR] [FLINK-41366][pipeline-connector/fluss] Support disabling automatic column addition [flink-cdc] fxbing (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41103][python] Clear ValueState without adding None in update(None) [flink] dianfu (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-34376][table] Fix DECIMAL precision loss in multiplication type inference [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/05 Re: [PR] [python][plan] Split chat model action into per-model attempts [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40609][python] Infer ROW types from dataclass, NamedTuple and tuple type hints [flink] dianfu (via GitHub) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-41330) VARIANT array access with a BIGINT index wraps around and returns the wrong element Ramin Gharib (Jira) via issues
• 2026/11/05 [jira] [Updated] (FLINK-39847) FLIP-578: Support in-place conversion of a table to a materialized table Yuepeng Pan (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-40966][pipeline-connector/fluss] Reuse metadata clients across schema operations [flink-cdc] loserwang1024 (via GitHub) via issues
• 2026/11/05 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] ykisana (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] ykisana (via GitHub) via issues
• 2026/11/05 [jira] [Comment Edited] (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/05 Re: [PR] [hotfix][docs] Fix typos in Hive dialect docs [flink] arvindKandpal-ksolves (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] kurnoolsaketh (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40962][table-planner] expose LEAD(TIMESTAMP_LTZ)/LAG(TIMESTAMP_LTZ) in batch mode [flink] kurnoolsaketh (via GitHub) via issues
• 2026/11/05 Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec.java [flink] flinkbot (via GitHub) via issues
• 2026/11/05 Re: [PR] [api][plan][runtime][java] Unify Future scheduling and tool execution [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] sqd (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] kurnoolsaketh (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] kurnoolsaketh (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] kurnoolsaketh (via GitHub) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Yuepeng Pan (Jira) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] sqd (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] rionmonster (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-40628) PyFlink TTL initialization can hang task threads and leave jobs stuck in INITIALIZING Dian Fu (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] rionmonster (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] rionmonster (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] rionmonster (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] rionmonster (via GitHub) via issues
• 2026/11/05 [jira] [Commented] (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/05 [jira] [Updated] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Rui Fan (Jira) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Rui Fan (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] sqd (via GitHub) via issues
• 2026/11/05 [PR] [BP-2.4][FLINK-41362][table] Reject VARIANT in primary key columns [flink] raminqaf (via GitHub) via issues
• 2026/11/05 Re: [PR] [BP-2.4][FLINK-41362][table] Reject VARIANT in primary key columns [flink] flinkbot (via GitHub) via issues
• 2026/11/05 [jira] [Closed] (FLINK-41362) Reject VARIANT in primary key columns Ramin Gharib (Jira) via issues
• 2026/11/05 [jira] [Resolved] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter Sergey Nuyanzin (Jira) via issues
• 2026/11/05 [jira] [Created] (FLINK-41365) Remove queue based polling from DDB Connector Abhi Gupta (Jira) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41328) GROUP BY, DISTINCT, UNION and a join on a MAP column split one value into several in streaming mode sepuri sai krishna (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41362][table] Reject VARIANT in primary key columns [flink] flinkbot (via GitHub) via issues
• 2026/11/05 [PR] [BP-2.4][FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down [flink] jnh5y (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] spuru9 (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed Dian Fu (Jira) via issues
• 2026/11/05 Re: [PR] [hotfix][ci] Build flink-shaded for e2e only once [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 Re: [I] [Feature][YAML] Support model router resource declarations [flink-agents] sangkyoonnam (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] gustavodemorais (via GitHub) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-41285) Release Testing: Verify FLIP-584: Support Pluggable Storage Backend for HistoryServer Yuepeng Pan (Jira) via issues
• 2026/11/05 Re: [PR] [docs][paimon] Add MySQL CDC Action migration guide [flink-cdc] yuxiqian (via GitHub) via issues
• 2026/11/05 Re: [PR] [hotfix][docs] Fix typos in Hive dialect docs [flink] flinkbot (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-37502][docs] Translate documentation for Disaggregated State Management into Chinese [flink] arvindKandpal-ksolves (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] gustavodemorais (via GitHub) via issues
• 2026/11/05 [jira] [Created] (FLINK-41332) COMPILE PLAN fails for a query with a UUID literal Ramin Gharib (Jira) via issues
• 2026/11/05 [jira] [Commented] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter Sergey Nuyanzin (Jira) via issues
• 2026/11/05 [jira] [Updated] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter Sergey Nuyanzin (Jira) via issues
• 2026/11/05 Re: [PR] [BP-2.3][FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Yuepeng Pan (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] gustavodemorais (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Rui Fan (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41313][pipeline-connector/fluss] Skip dropped or expired partitions during checkpoint restore [flink-cdc] loserwang1024 (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] RocMarshal (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-40534) Memory tuning config overrides are computed before the ScalingExecutorPlugin chain and persisted unchanged when a plugin modifies the scaling decision Shubhankar Sunil Unhale (Jira) via issues
• 2026/11/05 [PR] [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink] raminqaf (via GitHub) via issues
• 2026/11/05 [jira] [Resolved] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Yuepeng Pan (Jira) via issues
• 2026/11/05 [jira] [Created] (FLINK-41358) Streaming OVER window ordered by a non-time column (RANGE frame) drops all equal rows from the aggregate when one of them is retracted Yaoxuan Wu (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/05 Re: [PR] [BP-2.4][FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] RocMarshal (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] 1996fanrui (via GitHub) via issues
• 2026/11/05 Re: [PR] [BP-2.4][FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` [flink] flinkbot (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] gustavodemorais (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via issues
• 2026/11/05 Re: [PR] [api][plan][runtime][java] Unify Future scheduling and tool execution [flink-agents] sangkyoonnam (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to RexCall only in case of AND [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Closed] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion Yuepeng Pan (Jira) via issues
• 2026/11/05 [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink] raminqaf (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink] raminqaf (via GitHub) via issues
• 2026/11/05 Re: [PR] [BP-2.2][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-41345) Add VARIANT_OBJECT, VARIANT_ARRAY, VARIANT_NULL and TO_VARIANT Ramin Gharib (Jira) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 Nic Townsend (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table [flink] nictownsend (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table [flink] spuru9 (via GitHub) via issues
• 2026/11/05 [jira] [Comment Edited] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 Nic Townsend (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
• 2026/11/05 [PR] [hotfix][docs] Fix typos in Hive dialect docs [flink] arvindKandpal-ksolves (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink] Timm0 (via GitHub) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-37381) Typo in Join document Sergey Nuyanzin (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] twalthr (via GitHub) via issues
• 2026/11/05 [PR] [FLINK-41362][table] Reject VARIANT in primary key columns [flink] raminqaf (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] nictownsend (via GitHub) via issues
• 2026/11/05 [jira] [Closed] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout Gyula Fora (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-39615] [docs] Translate changelog.md documentation to Chinese [flink] arvindKandpal-ksolves (via GitHub) via issues
• 2026/11/05 [jira] [Commented] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Timo Walther (Jira) via issues
• 2026/11/05 [jira] [Created] (FLINK-41363) Make ALTER TABLE ADD statements idempotent Muhammad (Jira) via issues
• 2026/11/05 Re: [PR] [hotfix][ci] Do not run disk clean up if e2e is skipped [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating Ramin Gharib (Jira) via issues
• 2026/11/05 [PR] [FLINK-38647][connect/postgres] Support changelog-mode=upsert emitting REPLACE events [flink-cdc] dev-donghwan (via GitHub) via issues
• 2026/11/05 [PR] [FLINK-41361][core] Bound VARIANT object and array sizes by the value… [flink] raminqaf (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating ASF GitHub Bot (Jira) via issues
• 2026/11/05 [jira] [Commented] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter Sergey Nuyanzin (Jira) via issues
• 2026/11/05 [PR] [BP-2.4][FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] raminqaf (via GitHub) via issues
• 2026/11/05 [jira] [Closed] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment Ramin Gharib (Jira) via issues
• 2026/11/05 Re: [PR] [hotfix][ci] Do not run disk clean up if e2e is skipped [flink] flinkbot (via GitHub) via issues
• 2026/11/05 [I] [Tech Debt][api][runtime][java] Decouple external subagent extension APIs from runtime [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/05 [PR] [hotfix][ci] Do not run disk clean up if e2e is skipped [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Commented] (FLINK-37381) Typo in Join document Sergey Nuyanzin (Jira) via issues
• 2026/11/05 Re: [I] [runtime][python] Support TaskManager reuse across Flink Agents jobs [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/05 [jira] [Assigned] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Rui Fan (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-40494][docs] Document the UUID type [flink] raminqaf (via GitHub) via issues
• 2026/11/05 [jira] [Updated] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Rui Fan (Jira) via issues
• 2026/11/05 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] eemario (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-37381][docs] Fix typo in Join document [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [PR] [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Commented] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter Sergey Nuyanzin (Jira) via issues
• 2026/11/05 Re: [PR] [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to RexCall only in case of AND [flink] snuyanzin (via GitHub) via issues
• 2026/11/05 [jira] [Created] (FLINK-41352) [mongodb] Support change events larger than 16MB with $changeStreamSplitLargeEvent Sonal Maheshwari (Jira) via issues
• 2026/11/05 [jira] [Created] (FLINK-41360) 'raw.line-delimiter' leaves a U+FEFF on each value in UTF-16, does not unescape '\n' and splits on an empty value Ramin Gharib (Jira) via issues
• 2026/11/05 [PR] [hotfix][pipeline-connector/doris] Upgrade Doris connector to 26.3.0 [flink-cdc] ayers-ltd (via GitHub) via issues
• 2026/11/05 Re: [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink] mohsenrezaeithe (via GitHub) via issues
• 2026/11/04 [PR] [BP-3.7][docs][paimon] Add MySQL CDC Action migration guide [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/04 Re: [PR] [docs][paimon] Add MySQL CDC Action migration guide [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/04 Re: [PR] [hotfix][table] Treat missing predicates in MetadataFilterPushDownSpec as empty [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-41312][pipeline-connector/fluss] Retire dropped or expired partitions while running [flink-cdc] litiliu (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-41312][pipeline-connector/fluss] Retire dropped or expired partitions while running [flink-cdc] litiliu (via GitHub) via issues
• 2026/11/04 Re: [PR] [BP-2.4][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Created] (FLINK-41359) ORC format: filter push-down on a DOUBLE column drops rows when the column holds NaN (orc-core 1.5.6, ORC-629) Yaoxuan Wu (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-37381][docs] Fix typo in Join document [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-37381) Typo in Join document Arvind Kandpal (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-37381][docs] Fix typo in Join document [flink] arvindKandpal-ksolves (via GitHub) via issues
• 2026/11/04 [PR] [FLINK-37381][docs] Fix typo in Join document [flink] arvindKandpal-ksolves (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-34368][fs] Update GCS connector to 3.1.18 [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-34368][fs] Update GCS connector to 3.1.18 [flink] github-actions[bot] (via GitHub) via issues
• 2026/11/04 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/04 [PR] [hotfix][table] Treat missing predicates in MetadataFilterPushDownSpec as empty [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
• 2026/11/04 Re: [PR] [runtime] Fix action-state key collisions between event occurrences with identical attributes [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/04 [jira] [Created] (FLINK-41337) Add IS_VARIANT_NULL, VARIANT_TYPE, VARIANT_KEYS and VARIANT_EXISTS Ramin Gharib (Jira) via issues
• 2026/11/04 Re: [PR] [docs][paimon] Add MySQL CDC Action migration guide [flink-cdc] lvyanquan (via GitHub) via issues
• 2026/11/04 Re: [I] [Feature] Cross-language (Java/Python) agent spec parity test harness [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/04 [I] [Bug][runtime] Checkpoint drain waits for slow actions and escalates checkpoint aborts to task failures [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] Admaing (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] Admaing (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41355][table] Introduce async state version of StreamExecIntervalJoin [flink] flinkbot (via GitHub) via issues
• 2026/11/04 Re: [PR] [api][java][python] Propagate user context from request events to responses [flink-agents] eemario (via GitHub) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41348) Merge nested VARIANT modification calls into one pass Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41344) Add VARIANT_CONTAINS with a shared value-equality rule Ramin Gharib (Jira) via issues
• 2026/11/04 Re: [I] [Feature][YAML] Support model router resource declarations [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/04 Re: [PR] [docs][examples] Add MySQL to Fluss ingestion example [flink-cdc] leonardBang (via GitHub) via issues
• 2026/11/04 Re: [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view Ferenc Csaky (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] raminqaf (via GitHub) via issues
• 2026/11/04 [jira] [Created] (FLINK-41357) FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-41355][table] Introduce async state version of StreamExecIntervalJoin [flink] Copilot (via GitHub) via issues
• 2026/11/04 Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] semlanghi (via GitHub) via issues
• 2026/11/04 [jira] [Closed] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark Zhanghao Chen (Jira) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark Zhanghao Chen (Jira) via issues
• 2026/11/04 [jira] [Closed] (FLINK-37679) Improve the performance of Flink serialization Zhanghao Chen (Jira) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Rui Fan (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-41356][table] Support early fire in the async state interval join [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-41334) SQL Gateway JSON results and the JDBC driver cannot return a UUID column Ramin Gharib (Jira) via issues
• 2026/11/04 [PR] [FLINK-41356][table] Support early fire in the async state interval join [flink] minxhe (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41355][table] Introduce async state version of StreamExecIntervalJoin [flink] minxhe (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-41355) Introduce async state version of StreamExecIntervalJoin ASF GitHub Bot (Jira) via issues
• 2026/11/04 Re: [PR] [hotfix][table] Treat missing predicates in MetadataFilterPushDownSpec as empty [flink] flinkbot (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] ykisana (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-41329) Restore tests are absent for all seven Python stream ExecNodes, four of them stateful sepuri sai krishna (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] Savonitar (via GitHub) via issues
• 2026/11/04 Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] wenjin272 (via GitHub) via issues

• Earlier messages
• Later messages