issues  

Messages by Date

• 2026/08/07 [jira] [Resolved] (FLINK-40337) Preserve operator precedence in generated Janino expressions Xiqian Yu (Jira)
• 2026/08/07 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/08/07 Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] via GitHub
• 2026/08/07 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40169][table] Add target option to the EARLY_FIRE hint [flink] via GitHub
• 2026/08/07 [jira] [Assigned] (FLINK-40282) Expand and correct the concepts Glossary Danny Cranmer (Jira)
• 2026/08/07 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/08/07 Re: [PR] [BP-2.2][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• 2026/08/07 Re: [PR] [BP-2.3][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform [flink-cdc] via GitHub
• 2026/08/07 [PR] [BP-2.2][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• 2026/08/07 [PR] [FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• 2026/08/07 [jira] [Created] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend Mykola Lukashchuk (Jira)
• 2026/08/07 Re: [PR] [FLINK-40223][runtime] Support additional Flink SQL string functions in YAML Transform [flink-cdc] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40337][runtime] Preserve operator precedence in generated Janino expressions [flink-cdc] via GitHub
• 2026/08/07 Re: [PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents] via GitHub
• 2026/08/07 Re: [PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents] via GitHub
• 2026/08/07 [PR] [mysql] Preserve schema for no-op CREATE TABLE IF NOT EXISTS ... LIKE [flink-cdc] via GitHub
• 2026/08/07 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/07 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/07 [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc] via GitHub
• 2026/08/07 Re: [PR] [FLINK-39165] Prevent concurrent FlinkSessionJob / FlinkDeployment update [flink-kubernetes-operator] via GitHub
• 2026/08/07 [jira] [Assigned] (FLINK-40353) Leverage RocksDB ordered MapState TemporalRowTimeJoinOperator Piotr Nowojski (Jira)
• 2026/08/07 [jira] [Created] (FLINK-40353) Leverage RocksDB ordered MapState TemporalRowTimeJoinOperator Piotr Nowojski (Jira)
• 2026/08/07 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/07 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/08/07 [jira] [Created] (FLINK-40352) Add CloseableIterator support to MapState Piotr Nowojski (Jira)
• 2026/08/07 [jira] [Created] (FLINK-40351) Reduce heap footprint of RocksDBMapState's iterator Piotr Nowojski (Jira)
• 2026/08/07 Re: [PR] [FLINK-40271][table] Fix SQL serialization of Table API group window properties [flink] via GitHub
• 2026/08/07 [jira] [Commented] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates sepuri sai krishna (Jira)
• 2026/08/07 [jira] [Created] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates sepuri sai krishna (Jira)
• 2026/08/07 [PR] Flink Kubernetes Operator 1.16.0 [flink-web] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/07 Re: [PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/07 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/07 [jira] [Assigned] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Hongshun Wang (Jira)
• 2026/08/07 Re: [PR] [hotfix][ci] Bump GitHub script action to version 9 [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39722][pipeline-connector][fluss] Support Fluss CDC Yaml Source. [flink-cdc] via GitHub
• 2026/08/06 [jira] [Created] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Hongshun Wang (Jira)
• 2026/08/06 [PR] [hotfix][ci] Bump GitHub script action to version 9 [flink] via GitHub
• 2026/08/06 [jira] [Assigned] (FLINK-40347) Introduce scan.partition.boundary-query and scan.partition.use-physical-id config options Yuepeng Pan (Jira)
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 [jira] [Created] (FLINK-40348) ZSTD fails at runtime with the SQL Kafka Connector Kumar Mallikarjuna (Jira)
• 2026/08/06 Re: [PR] [FLINK-40169][table] Add target option to the EARLY_FIRE hint [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/08/06 [jira] [Updated] (FLINK-40347) Introduce scan.partition.boundary-query and scan.partition.use-physical-id config options Chanhae Oh (Jira)
• 2026/08/06 [jira] [Created] (FLINK-40347) Introduce scan.partition.boundary-query and scan.partition.use-physical-id config options Chanhae Oh (Jira)
• 2026/08/06 Re: [I] [Tech Debt] Add e2e test for submitting example to flink standalone cluster. [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [e2e][python] Stabilize standalone nightly example tests [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/08/06 [jira] [Commented] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225) Purushottam Sinha (Jira)
• 2026/08/06 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 [PR] [docs] Document Action trigger conditions [flink-agents] via GitHub
• 2026/08/06 [jira] [Commented] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" sepuri sai krishna (Jira)
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 [jira] [Created] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" sepuri sai krishna (Jira)
• 2026/08/06 [I] [Tech Debt] Python e2e tests set a non-existent checkpointing key, so they never checkpoint [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API [flink] via GitHub
• 2026/08/06 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 [jira] [Updated] (FLINK-40191) Add aggregation support to DataFrame API ASF GitHub Bot (Jira)
• 2026/08/06 [PR] [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API [flink] via GitHub
• 2026/08/06 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40169][table] Add target option to the EARLY_FIRE hint [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-34474][formats] Reset Avro decoder after a failed deserialization [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40345][checkpoint] Do not recycle the failed buffer twice in FilteringHandler [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 [PR] [FLINK-40345][checkpoint] Do not recycle the failed buffer twice in FilteringHandler [flink] via GitHub
• 2026/08/06 [jira] [Updated] (FLINK-40345) Buffer is recycled twice in FilteringHandler#recoverWithFiltering when delivery fails ASF GitHub Bot (Jira)
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 [jira] [Created] (FLINK-40345) Buffer is recycled twice in FilteringHandler#recoverWithFiltering when delivery fails Rui Fan (Jira)
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/06 Re: [D] [Discuss][Observability] OpenTelemetry GenAI export for Agent Traces (follow-up to #900) [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [integration] Add out of the box vLLM chat model support for Java and Python [flink-agents] via GitHub
• 2026/08/06 Re: [D] [Discuss][Observability] OpenTelemetry GenAI export for Agent Traces (follow-up to #900) [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [integration] Add out of the box vLLM chat model support for Java and Python [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40200][Checkpoint] Checkpoint sync phase timeout [flink] via GitHub
• 2026/08/06 [jira] [Closed] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer Ferenc Csaky (Jira)
• 2026/08/06 Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink] via GitHub
• 2026/08/06 [jira] [Resolved] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Rui Fan (Jira)
• 2026/08/06 Re: [PR] [FLINK-40326][core] Do not over-grant permits in GatedRateLimiter [flink] via GitHub
• 2026/08/06 Re: [PR] [integration] Add out of the box vLLM chat model support for Java and Python [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [integration] Add out of the box vLLM chat model support for Java and Python [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [hotfix][docs] Add feature-flag review guidelines to AGENTS.md [flink] via GitHub
• 2026/08/06 [PR] [hotfix][docs] Add feature-flag review guidelines to AGENTS.md [flink] via GitHub
• 2026/08/06 [jira] [Commented] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch Zakelly Lan (Jira)
• 2026/08/06 [jira] [Assigned] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch Zakelly Lan (Jira)
• 2026/08/06 Re: [PR] [FLINK-40326][core] Do not over-grant permits in GatedRateLimiter [flink] via GitHub
• 2026/08/06 [jira] [Closed] (FLINK-40339) WatermarkCompactingSinkMaterializer reads MapState entries after removing them Gustavo de Morais (Jira)
• 2026/08/06 Re: [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/06 Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40208][runtime] Add test coverage and blank-key validation for JobMdcRegistry [flink] via GitHub
• 2026/08/06 [jira] [Updated] (FLINK-39549) Compute OBSERVED_TPR for non-source vertices behind a feature flag for Operator Autoscaler Dennis-Mircea Ciupitu (Jira)
• 2026/08/06 [jira] [Updated] (FLINK-39549) Compute OBSERVED_TPR for non-source vertices behind a feature flag for Operator Autoscaler Dennis-Mircea Ciupitu (Jira)
• 2026/08/06 [jira] [Updated] (FLINK-39554) Support multiple custom autoscaler evaluators with deterministic ordering Dennis-Mircea Ciupitu (Jira)
• 2026/08/06 Re: [PR] [FLINK-40271][table] Fix SQL serialization of Table API group window properties [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/08/06 [PR] [e2e][python] Stabilize standalone nightly example tests [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-37925][table] Define CAST and TRY_CAST from VARIANT to scalar types [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-37925][table] Define CAST and TRY_CAST from VARIANT to scalar types [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink] via GitHub
• 2026/08/06 [jira] [Closed] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options Ferenc Csaky (Jira)
• 2026/08/06 Re: [PR] [FLINK-40143][core] Fix displayed restart strategy for config option based restart strategies [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/06 [jira] [Created] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations Liu Liu (Jira)
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 Re: [PR] [DOCS] List 3rd Party connector for NATS [flink] via GitHub
• 2026/08/06 Re: [PR] Update Flink Agents to 0.3.1 [flink-agents-demos] via GitHub
• 2026/08/06 [jira] [Resolved] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Yun Tang (Jira)
• 2026/08/06 Re: [PR] [FLINK-39984][runtime][webUI] Support LITE/FULL thread dump modes [flink] via GitHub
• 2026/08/06 [jira] [Closed] (FLINK-40089) Add JSON_LENGTH function Gustavo de Morais (Jira)
• 2026/08/06 Re: [PR] [FLINK-40089][table] Implement JSON_LENGTH function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/06 [jira] [Updated] (FLINK-40300) PyFlink Table API lit fails for some literal types Liu Liu (Jira)
• 2026/08/06 [jira] [Updated] (FLINK-40300) PyFlink Table API lit fails for some literal types Liu Liu (Jira)
• 2026/08/06 [jira] [Updated] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame ASF GitHub Bot (Jira)
• 2026/08/06 [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 [jira] [Updated] (FLINK-40339) WatermarkCompactingSinkMaterializer reads MapState entries after removing them ASF GitHub Bot (Jira)
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/06 [PR] [FLINK-40339][table] Do not read buffer entries after removing them [flink] via GitHub
• 2026/08/06 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/06 Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39320] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
• 2026/08/06 Re: [PR] [FLINK-39036][formats] Honor microsecond Avro timestamp logical types [flink] via GitHub
• 2026/08/06 Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] via GitHub
• 2026/08/06 Re: [PR] [hotfix] [pyflink] Fix Python Datastream JDBC Java method reference [flink] via GitHub
• 2026/08/06 Re: [PR] [DOCS] List 3rd Party connector for NATS [flink] via GitHub
• 2026/08/05 Re: [PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents] via GitHub
• 2026/08/05 [PR] Update Flink Agents to 0.3.1 [flink-agents-demos] via GitHub
• 2026/08/05 Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• 2026/08/05 Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• 2026/08/05 Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• 2026/08/05 Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• 2026/08/05 Re: [PR] [runtime][python] Refresh imports for new dependency generations [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [integration] Add out of the box vLLM chat model support for Java and Python [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [FLINK-40341] Bump jackson-bom to 2.21.5 [flink-kubernetes-operator] via GitHub
• 2026/08/05 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/05 Re: [D] [Discussion][Observability 2/2] Built-in Operational Metrics for Flink Agents [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [FLINK-34474][formats] Reset Avro decoder after a failed deserialization [flink] via GitHub
• 2026/08/05 Re: [PR] [hotfix][runtime] Close the Kafka consumer when the producer fails to close [flink-agents] via GitHub
• 2026/08/05 [jira] [Updated] (FLINK-34474) After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails ASF GitHub Bot (Jira)
• 2026/08/05 [PR] [FLINK-34474][formats] Reset Avro decoder after a failed deserialization [flink] via GitHub
• 2026/08/05 Re: [PR] [hotfix][runtime] Keep the table close failure when the connection close also fails [flink-agents] via GitHub
• 2026/08/05 [PR] [hotfix][runtime] Keep the table close failure when the connection close also fails [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/08/05 Re: [PR] [FLINK-40341] Bump jackson-bom to 2.21.5 [flink-kubernetes-operator] via GitHub
• 2026/08/05 Re: [PR] Stateless Flink State Snapshot [flink-kubernetes-operator] via GitHub
• 2026/08/05 Re: [PR] Stateless Flink State Snapshot [flink-kubernetes-operator] via GitHub
• 2026/08/05 [jira] [Closed] (FLINK-39356) FlinkStateSnapshot cleanup fails with NPE when status is null, permanently blocking CR and namespace deletion Gyula Fora (Jira)

• Earlier messages
• Later messages