issues  

Messages by Date

• 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
• 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-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 [PR] [runtime] Share execution identity across action state and graph calls [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] spoorthibasu (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec.java [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [BP-2.2][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] flinkbot (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [BP-2.4][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [PR] [BP-2.3][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to RexCall only in case of AND [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion Mohsen Rezaei (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40709] Add allowlist to exempt trusted hosts from jarURI restricted-host check [flink-kubernetes-operator] spuru9 (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-41285) Release Testing: Verify FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40577][table] Support ChangelogModes in ProcessTableFunctionTestHarness [flink] autophagy (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink] Timm0 (via GitHub) via issues
• 2026/11/04 Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents] wenjin272 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] spuru9 (via GitHub) via issues
• 2026/11/04 Re: [PR] [hotfix][test] Run testAcceptingOfferedSlotsWithoutResourceManagerConnected on a single threaded main executor [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-41291) Bump snappy-java to 1.1.10.12 Rui Fan (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] argoyal2212 (via GitHub) via issues
• 2026/11/04 [PR] [hotfix][test] Run testAcceptingOfferedSlotsWithoutResourceManagerConnected on a single threaded main executor [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view Ferenc Csaky (Jira) via issues
• 2026/11/04 [jira] [Commented] (FLINK-40833) JobManager and TaskManager logs are rolled at startup with log4j 2.25.2 and later Purushottam Sinha (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-41113][Build] Bump jackson, log4j and assertj [flink-connector-pulsar] boring-cyborg[bot] (via GitHub) via issues
• 2026/11/04 [PR] [FLINK-40955] Give up and remove finalizer after cleanup keeps failing [flink-kubernetes-operator] gyfora (via GitHub) via issues
• 2026/11/04 [PR] [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector [flink] gaborgsomogyi (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40955) Give up and remove finalizer after cleanup keeps failing with a timeout ASF GitHub Bot (Jira) via issues
• 2026/11/04 [PR] [BP-3.7][docs] Backport Docusaurus migration and documentation updates [flink-cdc] yuxiqian (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] ykisana (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] argoyal2212 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] argoyal2212 (via GitHub) via issues
• 2026/11/04 Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec & JobManagerProcessSpec [flink] garvitlnmiit (via GitHub) via issues
• 2026/11/04 Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec & JobManagerProcessSpec [flink] garvitlnmiit (via GitHub) via issues
• 2026/11/04 [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/04 Re: [PR] [FLINK-40954] Force delete pods stuck Terminating on cluster resourcecleanup timeout [flink-kubernetes-operator] gyfora (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40052][mysql] Roll back assigner status in addSplits to prevent NPE in createBinlogSplit [flink-cdc] github-actions[bot] (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40195] helm: use static webhook certificate Secret name [flink-kubernetes-operator] applike-ss (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink] raminqaf (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41297][clients] Close the PackagedProgram of REST run-application submissions [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [jira] [Created] (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/04 Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] argoyal2212 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] argoyal2212 (via GitHub) via issues
• 2026/11/04 [jira] [Created] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets Luo Zhengjie (Jira) via issues
• 2026/11/04 Re: [PR] [BP-2.4][FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [jira] [Created] (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/04 [jira] [Commented] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (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] [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/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 Re: [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 Re: [PR] [BP-1.20][FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink] flinkbot (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40962][table-planner] expose LEAD(TIMESTAMP_LTZ)/LAG(TIMESTAMP_LTZ) in batch mode [flink] snuyanzin (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] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-41014) Add an adaptive retry mode to the native S3 connector Gabor Somogyi (Jira) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Yuepeng Pan (Jira) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Yuepeng Pan (Jira) via issues
• 2026/11/04 [PR] [FLINK-40494][docs] Document the UUID type [flink] raminqaf (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-39615] [docs] Translate changelog.md documentation to Chinese [flink] RocMarshal (via GitHub) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Sergey Nuyanzin (Jira) 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 [jira] [Updated] (FLINK-41350) A materialized table left SUSPENDED by a failed table conversion cannot be resumed Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40318) Add a validation entry point for a VARIANT binary Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41347) Add VARIANT_MERGE Ramin Gharib (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40494][docs] Document the UUID type [flink] RocMarshal (via GitHub) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41349) Document building and editing VARIANT values in Java Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Comment Edited] (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/04 [jira] [Updated] (FLINK-41331) Move python header installation to docker image ASF GitHub Bot (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via issues
• 2026/11/04 [jira] [Commented] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format Yuepeng Pan (Jira) via issues
• 2026/11/04 [PR] [FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Created] (FLINK-41341) Add VARIANT_ARRAY_APPEND and TRY_VARIANT_ARRAY_APPEND Ramin Gharib (Jira) via issues
• 2026/11/04 Re: [PR] [BP-2.2][FLINK-39146] Update log4j to 2.25.3 [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 [PR] chore: update JOSDK to v5.6.3 [flink-kubernetes-operator] csviri (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40494][docs] Document the UUID type [flink] raminqaf (via GitHub) via issues
• 2026/11/04 Re: [PR] [BP-2.3][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink] RocMarshal (via GitHub) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format Yuepeng Pan (Jira) via issues
• 2026/11/04 [jira] [Comment Edited] (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/04 [jira] [Comment Edited] (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/04 Re: [PR] [BP-2.4][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] RocMarshal (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types Yuepeng Pan (Jira) via issues
• 2026/11/04 [jira] [Commented] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types Yuepeng Pan (Jira) 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 [jira] [Updated] (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/04 Re: [PR] [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41331][ci] Move python header installation to flink-ci-docker [flink] snuyanzin (via GitHub) via issues
• 2026/11/04 [jira] [Created] (FLINK-41351) Release Testing: Verify FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41350) A materialized table left SUSPENDED by a failed table conversion cannot be resumed Ramin Gharib (Jira) 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] [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink] raminqaf (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] Efrat19 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink] twalthr (via GitHub) 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 [jira] [Comment Edited] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Rui Fan (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Rui Fan (Jira) via issues
• 2026/11/04 [jira] [Commented] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Rui Fan (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 [jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Rui Fan (Jira) via issues
• 2026/11/04 [jira] [Commented] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Rui Fan (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] 1996fanrui (via GitHub) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41339) Add VARIANT_SET, VARIANT_INSERT and their TRY_ forms Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41342) Add VARIANT_STRIP_NULLS Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41343) Add Variant#normalize() and VARIANT_NORMALIZE Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41340) Add VARIANT_DELETE and VARIANT_PICK Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40318) Add IS_VALID_VARIANT Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41342) Add VARIANT_STRIP_NULLS Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Updated] (FLINK-40582) Add SCHEMA_OF_VARIANT and SCHEMA_OF_VARIANT_AGG built-in functions Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41346) Add VARIANT_OBJECT_AGG Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41343) Add Variant#normalize() and VARIANT_NORMALIZE Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41349) Document building and editing VARIANT values in Java Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41338) Add an edit API to VariantBuilder Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Closed] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Resolved] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Assigned] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Comment Edited] (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 [jira] [Comment Edited] (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/04 [jira] [Closed] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41335) Release Testing: Verify FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41334) SQL Gateway JSON results and the JDBC driver cannot return a UUID column Ramin Gharib (Jira) via issues
• 2026/11/04 [jira] [Created] (FLINK-41333) MIN, MAX and streaming COUNT(DISTINCT) reject the UUID type Ramin Gharib (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] Efrat19 (via GitHub) via issues
• 2026/11/04 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] Efrat19 (via GitHub) via issues

• Earlier messages
• Later messages