issues  

Messages by Date

• 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
• 2026/11/04 Re: [PR] [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink] flinkbot (via GitHub) via issues
• 2026/11/04 [jira] [Comment Edited] (FLINK-41014) Add an adaptive retry mode to the native S3 connector Gabor Somogyi (Jira) via issues
• 2026/11/04 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] spuru9 (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 [jira] [Updated] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41245) PyFlink mypy check fails on release-2.3: create_arrow_schema has no allow_nested parameter Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-41196) PyFlink pandas conversions and regular Python UDFs change TIMESTAMP_LTZ instants in non-UTC session time zones Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-34625) TTL doesn't seem to work in pyflink Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Updated] (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/03 [jira] [Updated] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets ASF GitHub Bot (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] dianfu (via GitHub) via issues
• 2026/11/03 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/03 Re: [I] [Tech Debt] [python] Remove setuptools<82 constraint after apache-flink upgrades to apache-beam>=2.66.0 [flink-agents] HsbcJone (via GitHub) via issues
• 2026/11/03 [PR] [FLINK-41297][clients] Close the PackagedProgram of REST run-application submissions [flink] jagath25 (via GitHub) via issues
• 2026/11/03 Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents] HsbcJone (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 Re: [PR] [BP-3.7][docs] Backport Docusaurus migration and documentation updates [flink-cdc] leonardBang (via GitHub) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets Luo Zhengjie (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets Luo Zhengjie (Jira) via issues
• 2026/11/03 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/03 [jira] [Updated] (FLINK-41317) [pipeline-connector/kafka] NullPointerException when serializing REPLACE events in canal-json and debezium-json ASF GitHub Bot (Jira) 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 [jira] [Commented] (FLINK-40596) Closing metric might lead to a number of test failure Rui Fan (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 Re: [PR] [BP-2.2][FLINK-39146] Update log4j to 2.25.3 [flink] spuru9 (via GitHub) via issues
• 2026/11/03 [jira] [Assigned] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [jira] [Updated] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED ASF GitHub Bot (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-39789) AvroSchemaConverter.convertToDataType(String) ignores local-timestamp-* and timestamp-nanos logical types, silently maps to BIGINT Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Resolved] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [hotfix][ci] Run python doc checks in parallel [flink] snuyanzin (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Rui Fan (Jira) via issues
• 2026/11/03 [PR] [BP-1.20][FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink] 1996fanrui (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 [jira] [Commented] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40989) MAP equality compares numeric values by reference Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [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/03 [jira] [Commented] (FLINK-41216) Retracting ROW_NUMBER Top-N emits +U before -U for rows moving up, so operators keyed by the input upsert key lose rows Rui Fan (Jira) via issues
• 2026/11/03 [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] 1996fanrui (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration Rui Fan (Jira) via issues
• 2026/11/03 [jira] [Created] (FLINK-41326) chore: update JOSDK to v5.6.3 Attila Mészáros (Jira) via issues
• 2026/11/03 Re: [PR] [hotfix][ci] Run python doc checks in parallel [flink] snuyanzin (via GitHub) via issues
• 2026/11/03 [jira] [Commented] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Jim Hughes (Jira) via issues
• 2026/11/03 Re: [PR] [BP-2.4][FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down [flink] flinkbot (via GitHub) via issues
• 2026/11/03 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/03 [PR] Bump io.opentelemetry:opentelemetry-api from 1.62.0 to 1.67.0 [flink-connector-pulsar] dependabot[bot] (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] argoyal2212 (via GitHub) via issues
• 2026/11/03 Re: [PR] [hotfix][ci] Remove obsolete libssl download for e2e netty-tcnative on Ubuntu 26.04 [flink] flinkbot (via GitHub) via issues
• 2026/11/03 Re: [PR] [hotfix][ci] Run python doc checks in parallel [flink] flinkbot (via GitHub) via issues
• 2026/11/03 Re: [PR] [hotfix][ci] Remove obsolete libssl download for e2e netty-tcnative on Ubuntu 26.04 [flink] snuyanzin (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] spuru9 (via GitHub) via issues
• 2026/11/03 [PR] [hotfix][ci] Run python doc checks in parallel [flink] snuyanzin (via GitHub) via issues
• 2026/11/03 [jira] [Comment Edited] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Rui Fan (Jira) via issues
• 2026/11/03 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] spuru9 (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] spuru9 (via GitHub) via issues
• 2026/11/03 Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] snuyanzin (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-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] snuyanzin (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] Bump com.google.guava:guava from 33.4.0-jre to 33.7.1-jre [flink-kubernetes-operator] dependabot[bot] (via GitHub) via issues
• 2026/11/03 [PR] [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table [flink] spuru9 (via GitHub) via issues

• Earlier messages
• Later messages