issues  

Messages by Date

• 2026/02/12 Re: [PR] [FLINK-35321] Ensure pendingCommitables metric is not re-registered when copying CommitableCollector [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-35321] Ensure pendingCommitables metric is not re-registered when copying CommitableCollector [flink] via GitHub
• 2026/02/12 [jira] [Created] (FLINK-39082) Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor (Jira)
• 2026/02/12 [jira] [Created] (FLINK-39081) FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor (Jira)
• 2026/02/12 Re: [PR] [FLINK-35321] Add flag for metric registration [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-35321] Add flag for metric registration [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-35321] Add flag for metric registration [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/12 [PR] [FLINK-35321] Add flag for metric registration [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/12 [jira] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 Re: [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-27661][Runtime / Metrics] PrometheusPushGatewayReporter support pushgateway http authentication [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] via GitHub
• 2026/02/12 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/02/12 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 Re: [PR] [FLINK-38916][table-planner] MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38999][lineage] License lineage files [flink-connector-kafka] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink] via GitHub
• 2026/02/12 [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• 2026/02/12 [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• 2026/02/12 [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• 2026/02/12 [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• 2026/02/12 [jira] [Created] (FLINK-39080) Missing license undetected by connector CI Efrat Levitan (Jira)
• 2026/02/12 [jira] [Created] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• 2026/02/12 Re: [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 Re: [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] via GitHub
• 2026/02/12 [jira] [Commented] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility Gabor Somogyi (Jira)
• 2026/02/12 [jira] [Updated] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation ASF GitHub Bot (Jira)
• 2026/02/12 [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39002][tests] Temporarily disable SSL in test_file_sink [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39002][tests] Temporarily disable SSL in test_file_sink [flink] via GitHub
• 2026/02/12 Re: [PR] Add Turkish Translation for Apache Flink Website [flink-web] via GitHub
• 2026/02/12 [jira] [Assigned] (FLINK-39002) Could not resolve ResourceManager because of NPE Piotr Nowojski (Jira)
• 2026/02/12 [jira] [Assigned] (FLINK-39002) Could not resolve ResourceManager because of NPE Piotr Nowojski (Jira)
• 2026/02/12 Re: [PR] Flink community blog February 2026 [flink-web] via GitHub
• 2026/02/12 Re: [PR] Flink community blog February 2026 [flink-web] via GitHub
• 2026/02/12 Re: [PR] Flink community blog February 2026 [flink-web] via GitHub
• 2026/02/12 Re: [PR] [FLINK-XXXXX][Web UI] Add Top N Metrics Dashboard for performance diagnostics [flink] via GitHub
• 2026/02/12 [PR] [FLINK-XXXXX][Web UI] Add Top N Metrics Dashboard for performance diagnostics [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39078] Disallow ON CONFLICT for non upsert sinks [flink] via GitHub
• 2026/02/12 [jira] [Updated] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks ASF GitHub Bot (Jira)
• 2026/02/12 [PR] [FLINK-39078] Disallow ON CONFLICT for non upsert sinks [flink] via GitHub
• 2026/02/12 [jira] [Created] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks Dawid Wysakowicz (Jira)
• 2026/02/12 Re: [PR] [FLINK-39077][table] Calculation of table changes for MT with several non persisted columns might fail [flink] via GitHub
• 2026/02/12 [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail ASF GitHub Bot (Jira)
• 2026/02/12 [PR] [FLINK-39077][table] Calculation of table changes for MT with several non persisted columns might fail [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
• 2026/02/12 [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• 2026/02/12 [jira] [Created] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• 2026/02/12 [jira] [Updated] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI featzhang (Jira)
• 2026/02/12 [jira] [Created] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI featzhang (Jira)
• 2026/02/12 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 [jira] [Commented] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• 2026/02/12 Re: [PR] [FLINK-XXXXX][Web UI] Display slot sharing group ID in operator nodes [flink] via GitHub
• 2026/02/12 [PR] [FLINK-XXXXX][Web UI] Display slot sharing group ID in operator nodes [flink] via GitHub
• 2026/02/12 [jira] [Updated] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility Sebastien Pereira (Jira)
• 2026/02/12 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [hotfix] Fix onnxruntime build failure on macOS x86_64 [flink-agents] via GitHub
• 2026/02/12 [jira] [Closed] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING Dawid Wysakowicz (Jira)
• 2026/02/12 Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink] via GitHub
• 2026/02/12 [jira] [Created] (FLINK-39075) fn_execution test collection fails in test_flink_fn_execution_pb2.py Samrat Deb (Jira)
• 2026/02/12 Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-39050][Table SQL/Planner] Support configurable handling strategy for null rowtime field in watermark generation [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 [jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL featzhang (Jira)
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/12 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL featzhang (Jira)
• 2026/02/11 Re: [PR] [FLINK-27661][Runtime / Metrics] PrometheusPushGatewayReporter support pushgateway http authentication [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" ASF GitHub Bot (Jira)
• 2026/02/11 [PR] [FLINK-8093][connectors/kafka] Add client.id.prefix support to KafkaSink [flink-connector-kafka] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/02/11 [jira] [Closed] (FLINK-18379) Introduce asynchronous UDF/UDTF Natea Eshetu Beshada (Jira)
• 2026/02/11 [jira] [Commented] (FLINK-18379) Introduce asynchronous UDF/UDTF Natea Eshetu Beshada (Jira)
• 2026/02/11 [jira] [Assigned] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Natea Eshetu Beshada (Jira)
• 2026/02/11 [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function featzhang (Jira)
• 2026/02/11 [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function featzhang (Jira)
• 2026/02/11 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function featzhang (Jira)
• 2026/02/11 [jira] [Closed] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types Natea Eshetu Beshada (Jira)
• 2026/02/11 [jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types Natea Eshetu Beshada (Jira)
• 2026/02/11 [jira] [Closed] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. Gyula Fora (Jira)
• 2026/02/11 Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management featzhang (Jira)
• 2026/02/11 [jira] [Updated] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode ASF GitHub Bot (Jira)
• 2026/02/11 [PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink] via GitHub
• 2026/02/11 [jira] [Assigned] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. Leonard Xu (Jira)
• 2026/02/11 [jira] [Created] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management featzhang (Jira)
• 2026/02/11 Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
• 2026/02/11 [jira] [Assigned] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry Natea Eshetu Beshada (Jira)
• 2026/02/11 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/02/11 [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
• 2026/02/11 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry ASF GitHub Bot (Jira)
• 2026/02/11 Re: [PR] [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/02/11 [PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/11 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. Hongshun Wang (Jira)
• 2026/02/11 Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• 2026/02/11 Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] via GitHub
• 2026/02/11 Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.1) [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.2) [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-38986][runtime][test] Update further tests with modern cipher suite [flink] via GitHub
• 2026/02/11 [jira] [Commented] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
• 2026/02/11 [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
• 2026/02/11 [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
• 2026/02/11 [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
• 2026/02/11 [jira] [Commented] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source Bowen Li (Jira)
• 2026/02/11 [jira] [Resolved] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source Bowen Li (Jira)
• 2026/02/11 Re: [PR] [FLINK-39012]Add global kafka enumerator support [flink-connector-kafka] via GitHub
• 2026/02/11 Re: [PR] [FLINK-39012]Add global kafka enumerator support [flink-connector-kafka] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-39040) allow additional json to be specified for the body request Ferenc Csaky (Jira)
• 2026/02/11 [jira] [Closed] (FLINK-39040) allow additional json to be specified for the body request Ferenc Csaky (Jira)
• 2026/02/11 [jira] [Assigned] (FLINK-39040) allow additional json to be specified for the body request Ferenc Csaky (Jira)
• 2026/02/11 Re: [PR] FLINK-39040 Additional body json for GenericJsonAndUrlQueryCreator [flink-connector-http] via GitHub
• 2026/02/11 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite [flink] via GitHub
• 2026/02/11 [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Gabor Somogyi (Jira)
• 2026/02/11 [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• 2026/02/11 [jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources ASF GitHub Bot (Jira)
• 2026/02/11 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/02/11 [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Yaroslav (Jira)
• 2026/02/11 Re: [PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 [PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 [jira] [Assigned] (FLINK-39073) Idle source splits are picked by watermark alignment Rui Fan (Jira)
• 2026/02/11 Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] via GitHub
• 2026/02/11 [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• 2026/02/11 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/02/11 Re: [PR] [hotfix] Wait for leader election to prevent OUT_OF_ORDER issues [flink-connector-kafka] via GitHub
• 2026/02/11 [jira] [Created] (FLINK-39073) Idle source splits are picked by watermark alignment Efrat Levitan (Jira)
• 2026/02/11 Re: [PR] [FLINK-30975] Upgrade hadoop to 3.4.X [flink] via GitHub

• Earlier messages