issues  

Messages by Date

• 2026/09/03 [PR] [hotfix][runtime] Raise Kafka admin future timeout from 100ms to 30s [flink-agents] via GitHub
• 2026/09/03 [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 [PR] [BP-2.3][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup ASF GitHub Bot (Jira)
• 2026/09/03 Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39725][python] Apply the Python TimestampAssigner in from_source [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40541][table-planner] Detect build-side watermark hidden by column expansion in LATERAL SNAPSHOT [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/03 [jira] [Resolved] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework Zakelly Lan (Jira)
• 2026/09/03 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder ASF GitHub Bot (Jira)
• 2026/09/03 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40541][table-planner] Detect build-side watermark hidden by column expansion in LATERAL SNAPSHOT [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [BP-1.20][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale [flink] via GitHub
• 2026/09/03 [jira] [Closed] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Dian Fu (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup Purushottam Sinha (Jira)
• 2026/09/03 [PR] [FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 [jira] [Resolved] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments Fabian Hueske (Jira)
• 2026/09/03 [PR] [BP-2.1][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/03 Re: [PR] [BP-2.3][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 Re: [PR] [BP-2.1][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 Re: [PR] [BP-2.2][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 [PR] [BP-2.2][FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40548][ci] Use image with ubuntu 24.04 [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [BP-1.20][FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes [flink] via GitHub
• 2026/09/03 Re: [PR] [BP-2.2][FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-40548) Bump ubuntu to 24.04 in flink-ci-docker Sergey Nuyanzin (Jira)
• 2026/09/03 [jira] [Resolved] (FLINK-40548) Bump ubuntu to 24.04 in flink-ci-docker Sergey Nuyanzin (Jira)
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ROW and STRUCTURED [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 [PR] [FLINK-37926][table] Support casting from VARIANT to ROW and STRUCTURED [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40550] Fix operator crash when reconcile.parallelism is -1 [flink-kubernetes-operator] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40545][table] Add parseJson() and tryParseJson() Table API expression methods [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40547][docs] Add page on interpreting Flink's changelog [flink] via GitHub
• 2026/09/03 [jira] [Created] (FLINK-40549) Split level metrics leak the closed metricGroup on split finish Efrat Levitan (Jira)
• 2026/09/03 [jira] [Updated] (FLINK-40547) Add "Interpreting Flink's SQL Changelog" concepts page ASF GitHub Bot (Jira)
• 2026/09/03 [jira] [Commented] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework Zakelly Lan (Jira)
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods ASF GitHub Bot (Jira)
• 2026/09/03 [PR] [FLINK-40545][table] Add parseJson() and tryParseJson() Table API expression methods [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40547][docs] Add page on interpreting Flink's changelog [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods Mate Czagany (Jira)
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40548) Bump ubuntu to 24.04 in flink-ci-docker ASF GitHub Bot (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40548) Bump ubuntu to 24.04 in flink-ci-docker Sergey Nuyanzin (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40547) Add "Interpreting Flink's SQL Changelog" concepts page Gustavo de Morais (Jira)
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39986][table-planner][python] Support full-tree CSE for nested Python UDF calls [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-34527) Deprecate Time classes also in PyFlink Bhanu Chander Vallabaneni (Jira)
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 [jira] [Created] (FLINK-40546) Automatically extract java.util.UUID as the UUID type in the DataStream API Ramin Gharib (Jira)
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods Timo Walther (Jira)
• 2026/09/03 [jira] [Commented] (FLINK-35273) PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone Bhanu Chander Vallabaneni (Jira)
• 2026/09/03 [jira] [Commented] (FLINK-35439) Python Support for AvroSchemaConverter Bhanu Chander Vallabaneni (Jira)
• 2026/09/03 Re: [PR] [FLINK-XXXXX] [runtime] Detach per-split source metric groups when splits finish [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-40430) Add configuration support to DataFrame API Federico Dolce (Jira)
• 2026/09/03 Re: [PR] [FLINK-39986][table-planner][python] Support full-tree CSE for nested Python UDF calls [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39986][table-planner][python] Support full-tree CSE for nested Python UDF calls [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 [PR] [FLINK-XXXXX] [runtime] Detach per-split source metric groups when splits finish [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39977][runtime] Recovery of merged channel state handles [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39977][runtime] Recovery of merged channel state handles [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40379][runtime] Wait for pre-restart parallelism to become available again after a rescale-triggered restart [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40370][python] Frame bytes-backed decimals as a bytes field [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 Re: [PR] FLINK-40245 Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBui… [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/09/03 Re: [PR] [FLINK-39724][python] Support InternalTypeInfo in PyFlink type extraction [flink] via GitHub
• 2026/09/03 [jira] [Resolved] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Sergey Nuyanzin (Jira)
• 2026/09/03 [jira] [Commented] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Sergey Nuyanzin (Jira)
• 2026/09/03 Re: [PR] [FLINK-40541][table-planner] Detect build-side watermark hidden by column expansion in LATERAL SNAPSHOT [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Federico Dolce (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods Ramin Gharib (Jira)
• 2026/09/03 [jira] [Updated] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods Timo Walther (Jira)
• 2026/09/03 [jira] [Updated] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods Ramin Gharib (Jira)
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• 2026/09/03 Re: [PR] Flink dataframe configuration [flink] via GitHub
• 2026/09/03 [PR] Flink dataframe configuration [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40477][table] Fix constraint enforcer for partial deletes [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40370][python] Frame bytes-backed decimals as a bytes field [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40490) Runtime serialization and codegen for UUID ASF GitHub Bot (Jira)
• 2026/09/03 Re: [PR] [FLINK-40541][table-planner] Detect build-side watermark hidden by column expansion in LATERAL SNAPSHOT [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40490][table] Add runtime serialization and codegen for the UUID type [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/09/03 [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 [jira] [Created] (FLINK-40544) Add raw format support for UUID type Ramin Gharib (Jira)
• 2026/09/03 Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [][] Deregister closed metric groups [flink] via GitHub
• 2026/09/03 [jira] [Resolved] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement Fabian Hueske (Jira)
• 2026/09/03 [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 [PR] [][] Deregister closed metric groups [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40541][table-planner] Detect build-side watermark hidden by column expansion in LATERAL SNAPSHOT [flink] via GitHub
• 2026/09/03 Re: [PR] Notice change [flink-connector-http] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40541) LATERAL SNAPSHOT join rejects a valid build-side watermark when it is declared on a column hidden by the column-expansion strategy ASF GitHub Bot (Jira)
• 2026/09/03 [PR] [FLINK-40541][table-planner] Detect build-side watermark hidden by column expansion in LATERAL SNAPSHOT [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) ASF GitHub Bot (Jira)
• 2026/09/03 Re: [PR] [FLINK-40421][python] Add sorting APIs to DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 [PR] [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses [flink] via GitHub
• 2026/09/03 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40543) Race condition and ConcurrentModificationException in MockSplitEnumeratorContext.getSentSourceEvent() Sylwester Lachiewicz (Jira)
• 2026/09/03 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/03 [jira] [Created] (FLINK-40543) Race condition and ConcurrentModificationException in MockSplitEnumeratorContext.getSentSourceEvent() Sylwester Lachiewicz (Jira)
• 2026/09/03 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest [flink-connector-kafka] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40421][python] Add sorting APIs to DataFrame API [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40477][table] Fix constraint enforcer for partial deletes [flink] via GitHub
• 2026/09/03 [jira] [Resolved] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Rui Fan (Jira)
• 2026/09/03 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/09/03 [I] [Tech Debt][API][Tool] Separate function-schema derivation from API contracts [flink-agents] via GitHub
• 2026/09/03 [PR] [runtime][java] Make embedded Python interpreters thread-confined [flink-agents] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40540][table-planner] Put the rule's reason first in the planning error [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40421][python] Add sorting APIs to DataFrame API [flink] via GitHub
• 2026/09/03 [jira] [Commented] (FLINK-36605) Upgrade Debezium version to 2.7.x Jira
• 2026/09/03 [PR] [FLINK-40421][python] Add sorting APIs to DataFrame API [flink] via GitHub
• 2026/09/03 [jira] [Updated] (FLINK-40421) Add sorting support in DataFrame API ASF GitHub Bot (Jira)
• 2026/09/03 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/03 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub

• Earlier messages