issues  

Messages by Date

• 2026/07/19 [jira] [Created] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API Dian Fu (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40195) Flink kubernetes operator certificate secret name should be configurable Jira
• 2026/07/19 [jira] [Created] (FLINK-40196) Add missing-value handling to DataFrame API Dian Fu (Jira)
• 2026/07/19 Re: [PR] [FLINK-40148][common] Fix TableIdRouter producing wrong sink table for multi-digit source suffix [flink-cdc] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40194) Add drop_duplicates to DataFrame API Dian Fu (Jira)
• 2026/07/19 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40151][runtime] Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation [flink-cdc] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40193) Add join_lateral support to DataFrame API Dian Fu (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40191) Add aggregation support to DataFrame API Dian Fu (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame Dian Fu (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame Dian Fu (Jira)
• 2026/07/19 [PR] [helm] Make webhook certificate secret name configurable [flink-kubernetes-operator] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame Dian Fu (Jira)
• 2026/07/19 Re: [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40189) Found Security Vunerability in IndexGeneratorFactory.java Taranpreet Kaur (Jira)
• 2026/07/19 Re: [I] [Bug] Anthropic chat model crashes on a tool_use response with no text block [flink-agents] via GitHub
• 2026/07/19 Re: [PR] [integration][anthropic] Don't assume the first content block is text [flink-agents] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40188) Check connection string at the start of job for opensearch distributor Taranpreet Kaur (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40187) Introduce DataType class in DataFrame API Dian Fu (Jira)
• 2026/07/19 Re: [D] [Discussion] Agent observability: tracing & evaluation beyond metrics + event log [flink-agents] via GitHub
• 2026/07/19 [jira] [Assigned] (FLINK-40186) Support the basic functionality of DataFrame API Dian Fu (Jira)
• 2026/07/19 Re: [I] [Feature] Track token usage metrics for embedding models [flink-agents] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40186) Support the basic functionality of DataFrame API Dian Fu (Jira)
• 2026/07/19 Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents] via GitHub
• 2026/07/19 Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40185) Introduce DataFrame API in PyFlink Dian Fu (Jira)
• 2026/07/19 [jira] [Commented] (FLINK-40152) PostgreSQL CDC connector captures case-variant tables when only one is specified ouyangwulin (Jira)
• 2026/07/19 Re: [D] [Discussion][Observability 2/2] Built-in Operational Metrics for Flink Agents [flink-agents] via GitHub
• 2026/07/19 Re: [D] [Discussion][Observability 1/2] Recording Agent Traces in the Event Log [flink-agents] via GitHub
• 2026/07/19 Re: [D] [Discussion][Observability 1/2] Recording Agent Traces in the Event Log [flink-agents] via GitHub
• 2026/07/19 Re: [D] [Discussion][Observability 1/2] Recording Agent Traces in the Event Log [flink-agents] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][ci] Make spotless checking changes since last green build in ci [flink] via GitHub
• 2026/07/19 [jira] [Updated] (FLINK-40184) Remove inconsistency checks from DynamoDB Connector ASF GitHub Bot (Jira)
• 2026/07/19 [PR] [FLINK-40184][Connectors/DynamoDB] Remove DescribeStream inconsistency-resolution check from shard discovery [flink-connector-aws] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40184][Connectors/DynamoDB] Remove DescribeStream inconsistency-resolution check from shard discovery [flink-connector-aws] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40184) Remove inconsistency checks from DynamoDB Connector Abhi Gupta (Jira)
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE ASF GitHub Bot (Jira)
• 2026/07/19 Re: [PR] [FLINK-40182][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][ci] Make spotless checking changes since last green build in ci [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40158][table-planner] Support LATERAL SNAPSHOT join in batch mode [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40183] test: cover checkpoint coordinator scheduling [flink] via GitHub
• 2026/07/19 [jira] [Updated] (FLINK-40183) Add regression coverage for CheckpointCoordinator scheduling ASF GitHub Bot (Jira)
• 2026/07/19 Re: [PR] [FLINK-40183] test: cover checkpoint coordinator scheduling [flink] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40183) Add regression coverage for CheckpointCoordinator scheduling amirhossein deljouyi (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 [PR] [FLINK-40181][table] ArrayToArray and MapToMap cast rules generate code which might fail with NPE [flink] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40182) ArrayToArray and MapToMap generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 [jira] [Updated] (FLINK-40182) ArrayToArray and MapToMap cast rules generate code which might fail with NPE Sergey Nuyanzin (Jira)
• 2026/07/19 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-40181][ci] Make spotless checking changes since last green build in ci [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 [jira] [Updated] (FLINK-40181) Make spotless checking changes since last green build in ci ASF GitHub Bot (Jira)
• 2026/07/19 [PR] [FLINK-40181][ci] Make spotless checking changes since last green build in ci [flink] via GitHub
• 2026/07/19 [jira] [Created] (FLINK-40181) Make spotless checking changes since last green build in ci Sergey Nuyanzin (Jira)
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/19 [jira] [Updated] (FLINK-40177) Support reading Keyed and Flattened Keyed states in StateCatalog Gyula Fora (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40179) Support windowed states in state catalog Gyula Fora (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40180) Non-keyed state support in StateCatalog Gyula Fora (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40178) Keyed state cataloging integration test Gyula Fora (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40177) Support reading Keyed and Flattened Keyed states Gyula Fora (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40176) Introduce basic StateCatalog functionality Gyula Fora (Jira)
• 2026/07/19 [jira] [Created] (FLINK-40175) FLIP-599: State Catalog Gyula Fora (Jira)
• 2026/07/19 Re: [PR] [FLINK-39079][Web Frontend] Add Diagnosis Advisor to Flink Web UI [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink] via GitHub
• 2026/07/19 Re: [PR] [FLINK-39079][Web Frontend] Add Diagnosis Advisor to Flink Web UI [flink] via GitHub
• 2026/07/18 Re: [PR] [FLINK-40151][runtime] Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation [flink-cdc] via GitHub
• 2026/07/18 Re: [PR] [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) [flink-agents] via GitHub
• 2026/07/18 [PR] [integrations][openai] Apply OpenAI native structured output [flink-agents] via GitHub
• 2026/07/18 [jira] [Resolved] (FLINK-40161) Log original MySQL DDL events before parsing Yanquan Lv (Jira)
• 2026/07/18 [jira] [Assigned] (FLINK-40161) Log original MySQL DDL events before parsing Yanquan Lv (Jira)
• 2026/07/18 Re: [PR] [FLINK-40161] Log original MySQL DDL events before parsing [flink-cdc] via GitHub
• 2026/07/18 [jira] [Commented] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang (Jira)
• 2026/07/18 [jira] [Updated] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation ASF GitHub Bot (Jira)
• 2026/07/18 Re: [PR] [FLINK-40167][table] Add EARLY_FIRE join hint surface and option validation [flink] via GitHub
• 2026/07/18 [jira] [Commented] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40174) Document the EARLY_FIRE hint for interval joins Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40173) Add restore coverage for early-fire interval join Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40171) Emit and retract early-fire results in the interval join operator Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40170) Infer update-producing changelog mode for early-fire interval join Weiqing Yang (Jira)
• 2026/07/18 [jira] [Updated] (FLINK-40169) Add target option to the EARLY_FIRE hint Weiqing Yang (Jira)
• 2026/07/18 Re: [PR] [infra] Add a coding-agent development skill [flink-agents] via GitHub
• 2026/07/18 [jira] [Created] (FLINK-40169) Add target option to the EARLY_FIRE hint Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation Weiqing Yang (Jira)
• 2026/07/18 [jira] [Created] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join Weiqing Yang (Jira)
• 2026/07/18 Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
• 2026/07/18 Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
• 2026/07/18 Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
• 2026/07/18 Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
• 2026/07/18 Re: [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents] via GitHub
• 2026/07/18 Re: [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents] via GitHub
• 2026/07/18 Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
• 2026/07/18 Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
• 2026/07/18 Re: [I] [Bug] create_model_from_java_tool_schema_str crashes on a Java tool param without a description [flink-agents] via GitHub
• 2026/07/18 Re: [PR] [python] Tolerate Java tool params without a description [flink-agents] via GitHub
• 2026/07/17 Re: [PR] [FLINK-38997] Fix StateTransitionManager stuck in Transitioning phase on failed transition [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-38997] Fix StateTransitionManager stuck in Transitioning phase on failed transition [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40020][release] Generate reference data for state migration tests based on release 2.3.0 [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40101][runtime] Emit intermediate watermarks while firing timers [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40166][table] SQL query parsing fails if current catalog unreachable [flink] via GitHub
• 2026/07/17 [jira] [Updated] (FLINK-40166) SQL query parsing fails if current catalog is unreachable Dale Lane (Jira)
• 2026/07/17 [jira] [Commented] (FLINK-40166) SQL query parsing fails if current catalog is unreachable Dale Lane (Jira)
• 2026/07/17 [jira] [Updated] (FLINK-40166) SQL query parsing fails if current catalog is unreachable ASF GitHub Bot (Jira)
• 2026/07/17 [PR] [FLINK-40166][table] SQL query parsing fails if current catalog unreachable [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 [jira] [Created] (FLINK-40166) SQL query parsing fails if current catalog is unreachable Dale Lane (Jira)
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40101][runtime] Emit intermediate watermarks while firing timers [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-39523] Checkpoint coordination during recovery (memory-based trigger) [flink] via GitHub
• 2026/07/17 Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
• 2026/07/17 [jira] [Comment Edited] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot Weiqing Yang (Jira)
• 2026/07/17 [jira] [Commented] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot Weiqing Yang (Jira)
• 2026/07/17 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink] via GitHub
• 2026/07/17 [PR] [infra] Add a coding-agent development skill [flink-agents] via GitHub
• 2026/07/17 [I] [Feature] Add a coding-agent development skill for Flink Agents applications [flink-agents] via GitHub
• 2026/07/17 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/07/17 Re: [PR] [BP-2.3][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.2][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.0][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.1][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.0][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.0][FLINK-40086][runtime] Adds error handling to newly added preCompletionAction [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.0][FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/07/17 Re: [PR] [BP-2.0][FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/07/17 [PR] [BP-2.3][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 [PR] [BP-2.2][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 [PR] [BP-2.1][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 [PR] [BP-2.0][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40158][table-planner] Support LATERAL SNAPSHOT join in batch mode [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40163] [ci] Add new baseline nightly build to Github Actions [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40163] [ci] Add new baseline nightly build to Github Actions [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-40158][table-planner] Support LATERAL SNAPSHOT join in batch mode [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
• 2026/07/17 [jira] [Resolved] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes Rui Fan (Jira)
• 2026/07/17 Re: [PR] [FLINK-40101][runtime] Emit intermediate watermarks while firing timers [flink] via GitHub
• 2026/07/17 Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
• 2026/07/17 [jira] [Commented] (FLINK-40020) Flink 2.3: update reference data for migration tests David Anderson (Jira)
• 2026/07/17 Re: [PR] [FLINK-40020][release] Generate reference data for state migration tests based on release 2.3.0 [flink] via GitHub

• Earlier messages
• Later messages