issues  

Messages by Date

• 2026/08/23 Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/23 [jira] [Comment Edited] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
• 2026/08/23 Re: [PR] [hotfix][e2e] Derive recovery test version from project [flink-agents] via GitHub
• 2026/08/23 [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
• 2026/08/23 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/23 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/23 [PR] [hotfix][ci] Bump setup maven action to v5 [flink-shaded] via GitHub
• 2026/08/23 [PR] [hotfix][ci] Bump checkout action to v7 [flink-shaded] via GitHub
• 2026/08/23 [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/23 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/23 [jira] [Commented] (FLINK-40292) Add UdfMetrics helper for UDF metrics Yuepeng Pan (Jira)
• 2026/08/23 [jira] [Resolved] (FLINK-40292) Add UdfMetrics helper for UDF metrics Yuepeng Pan (Jira)
• 2026/08/23 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/23 Re: [PR] [runtime][python] Refresh imports for new dependency generations [flink-agents] via GitHub
• 2026/08/23 [PR] [hotfix] Update to 22.0 version [flink-shaded] via GitHub
• 2026/08/23 Re: [PR] [runtime] Resolve relative file: URLs when loading classpath skills (#966) [flink-agents] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40139] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/08/23 Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/23 Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/23 Re: [PR] [FLINK-38397][table] Fix stale sort trait on BatchPhysicalLocalHashAggregate causing ArrayIndexOutOfBoundsException [flink] via GitHub
• 2026/08/23 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39404][runtime] HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits [flink] via GitHub
• 2026/08/22 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [FLINK-37981][table] TableAsyncExecutionController sends Long.MAX watermark downstream in endInput [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-38075][table] Fix data loss in tumble/hop/cumulate windows with LTZ for non-DST timezones [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39404][runtime] HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-36472][table] Preserve right-side projections when converting Correlate to physical [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-38075][table] Fix data loss in tumble/hop/cumulate windows with LTZ for non-DST timezones [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-37981][table] TableAsyncExecutionController sends Long.MAX watermark downstream in endInput [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-38397][table] Fix stale sort trait on BatchPhysicalLocalHashAggregate causing ArrayIndexOutOfBoundsException [flink] via GitHub
• 2026/08/22 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink] via GitHub
• 2026/08/22 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 [PR] [hotfix][e2e] Derive recovery test version from project [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [runtime] Resolve relative file: URLs when loading classpath skills (#966) [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/22 [PR] [python][java][integrations][plan] Handle finish_reason in OpenAI-family connections [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents] via GitHub
• 2026/08/22 Re: [I] [Bug][security][skills] Protect URL skill sources with secure transport and integrity verification [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) [flink-agents] via GitHub
• 2026/08/22 [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/22 [I] [Tech Debt] Update the stale Anthropic default model claude-sonnet-4-20250514 to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [integrations][java][python] Apply Anthropic native structured output [flink-agents] via GitHub
• 2026/08/22 [PR] [integrations][java][python] Stop sending temperature to Anthropic models that reject it [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [e2e] Add a checkpoint-recovery test for restored Python state [flink-agents] via GitHub
• 2026/08/22 [I] [Bug] [integrations][anthropic] temperature defaults to 0.1 and is always sent, returning HTTP 400 on Claude 4.7 and later [flink-agents] via GitHub
• 2026/08/22 [I] [Tech Debt] bats test bodies run under bash 3.2, so non-final [[ ]] assertions never fail [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-39874][s3] Make temp-file cleanup idempotent in NativeS3RecoverableFsDataOutputStream [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40382][build] Stop surefire from hiding nested test classes [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/22 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40382][build] Stop surefire from hiding nested test classes [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/22 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/22 [jira] [Commented] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Sergey Nuyanzin (Jira)
• 2026/08/22 [jira] [Assigned] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Sergey Nuyanzin (Jira)
• 2026/08/22 [jira] [Resolved] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Sergey Nuyanzin (Jira)
• 2026/08/22 Re: [PR] [FLINK-36298][table-planner] Re-establish Calcite metadata provider on foreign threads [flink] via GitHub
• 2026/08/22 [jira] [Resolved] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• 2026/08/22 [jira] [Updated] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• 2026/08/22 [jira] [Commented] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• 2026/08/22 Re: [PR] [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes [flink] via GitHub
• 2026/08/21 Re: [PR] [FLINK-39741][python] Add type hints and fix docstrings in datastream/functions.py [flink] via GitHub
• 2026/08/21 Re: [PR] [FLINK-39028][state] Use ByteBuffer API to reduce GC pressure in RocksDB state backend [flink] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40457][rpc] Bump Pekko to 1.7.0 [flink] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40457) Bump pekko to 1.7.0 ASF GitHub Bot (Jira)
• 2026/08/21 [PR] [FLINK-40457][rpc] Bump Pekko to 1.7.0 [flink] via GitHub
• 2026/08/21 [jira] [Created] (FLINK-40457) Bump pekko to 1.7.0 Sergey Nuyanzin (Jira)
• 2026/08/21 Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry ASF GitHub Bot (Jira)
• 2026/08/21 [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• 2026/08/21 [I] [Feature] Add checkpoint-aligned cleanup for Kafka action state [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink] via GitHub
• 2026/08/21 Re: [PR] [FLINK-39604][table] Show state and PTF capabilities in DESCRIBE FUNCTION EXTENDED [flink] via GitHub
• 2026/08/21 [jira] [Created] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 [jira] [Closed] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed Gustavo de Morais (Jira)
• 2026/08/21 [PR] [runtime] Resolve relative file: URLs when loading classpath skills (#966) [flink-agents] via GitHub
• 2026/08/21 [jira] [Created] (FLINK-40455) Decoupling Autotuning from the Autoscaling logic Dennis-Mircea Ciupitu (Jira)
• 2026/08/21 Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 [jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• 2026/08/21 Re: [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates ASF GitHub Bot (Jira)
• 2026/08/21 [jira] [Commented] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" sepuri sai krishna (Jira)
• 2026/08/21 [jira] [Commented] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates sepuri sai krishna (Jira)
• 2026/08/21 [PR] [FLINK-40350][table-runtime] Measure LPAD/RPAD length in characters [flink] via GitHub
• 2026/08/21 Re: [PR] Port fixes for 1.16 RC2 [flink-kubernetes-operator] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40455) Decoupling Autotuning from the Autoscaling logic Dennis-Mircea Ciupitu (Jira)
• 2026/08/21 Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40447][table] Fall back to retract when input upsert key is empty or mixed [flink] via GitHub
• 2026/08/21 [jira] [Created] (FLINK-40454) java.lang.NoSuchMethodError: '...Configuration.getInteger(..)' in FlinkConfigManager Vladislav Keda (Jira)
• 2026/08/21 [jira] [Assigned] (FLINK-40194) Add drop_duplicates to DataFrame API Dian Fu (Jira)
• 2026/08/21 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/21 [PR] Backport fixes for 1.16 RC2 [flink-kubernetes-operator] via GitHub
• 2026/08/21 [jira] [Closed] (FLINK-39570) Update Flink Shaded dependencies Ferenc Csaky (Jira)
• 2026/08/21 Re: [PR] [FLINK-39570] Update dependencies to latest versions [flink-shaded] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-39570) Update Flink Shaded dependencies Ferenc Csaky (Jira)
• 2026/08/21 [PR] Testing operator with next minor version of JOSDK [flink-kubernetes-operator] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter ASF GitHub Bot (Jira)
• 2026/08/21 [jira] [Updated] (FLINK-40452) Kubernetes Operator: Cap exception fetching by size, not line count Robert Metzger (Jira)
• 2026/08/21 [PR] [FLINK-40453][postgres] Not load table schema when initializing record emitter [flink-cdc] via GitHub
• 2026/08/21 [jira] [Created] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter YangyangHu (Jira)
• 2026/08/21 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission ASF GitHub Bot (Jira)
• 2026/08/21 [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/21 Re: [I] [Tech Debt] Add end-to-end checkpoint-recovery test for built-in tool-context [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [e2e] Add a checkpoint-recovery test for restored Python state [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink] via GitHub
• 2026/08/21 [jira] [Updated] (FLINK-40417) Add remaining basic functionality to DataFrame API ASF GitHub Bot (Jira)
• 2026/08/21 [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink] via GitHub
• 2026/08/21 Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
• 2026/08/21 [jira] [Created] (FLINK-40452) Cap exception fetching by size, not line count Robert Metzger (Jira)
• 2026/08/21 Re: [I] [Feature] Use descriptive thread names for Java and Python async executors [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents] via GitHub
• 2026/08/21 Re: [PR] [FLINK-40447][table] Fall back to retract when input upsert key is empty or mixed [flink] via GitHub
• 2026/08/21 [jira] [Resolved] (FLINK-40402) Add connect / read timeout to K8s operator artifact fetcher Robert Metzger (Jira)
• 2026/08/21 Re: [PR] [FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion [flink-kubernetes-operator] via GitHub
• 2026/08/21 [jira] [Commented] (FLINK-40431) Add UDF support to DataFrame API Federico Dolce (Jira)
• 2026/08/21 [jira] [Assigned] (FLINK-40431) Add UDF support to DataFrame API Dian Fu (Jira)
• 2026/08/20 Re: [PR] [Bug] Recovered Durable ActionState for keys owned by other subtasks is never pruned [flink-agents] via GitHub
• 2026/08/20 Re: [PR] [FLINK-39210][table] Fixed Memory Leak Issue in Flink SQL with Multiple Temporal Joins [flink] via GitHub
• 2026/08/20 Re: [PR] [FLINK-37912][Python] Add generic typing to DataStream interfaces [flink] via GitHub
• 2026/08/20 Re: [PR] [FLINK-39677][table] Fix ARRAY_SORT comparator contract violation [flink] via GitHub
• 2026/08/20 Re: [PR] [FLINK-39076][Web UI] Display slot sharing group in operator nodes [flink] via GitHub
• 2026/08/20 Re: [PR] [FLINK-39210][table] Fixed Memory Leak Issue in Flink SQL with Multiple Temporal Joins [flink] via GitHub
• 2026/08/20 Re: [PR] [FLINK-39076][Web UI] Display slot sharing group in operator nodes [flink] via GitHub
• 2026/08/20 [jira] [Commented] (FLINK-40431) Add UDF support to DataFrame API Liu Liu (Jira)
• 2026/08/20 Re: [PR] [Bug] Recovered Durable ActionState for keys owned by other subtasks is never pruned [flink-agents] via GitHub
• 2026/08/20 Re: [PR] [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes [flink] via GitHub
• 2026/08/20 [jira] [Updated] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes ASF GitHub Bot (Jira)
• 2026/08/20 [PR] [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes [flink] via GitHub
• 2026/08/20 [jira] [Created] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• 2026/08/20 [jira] [Commented] (FLINK-40431) Add UDF support to DataFrame API Dian Fu (Jira)
• 2026/08/20 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/08/20 [jira] [Assigned] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/08/20 [PR] Fix #985: Handle PydanticInvalidForJsonSchema for unserializable BaseModel [flink-agents] via GitHub
• 2026/08/20 [jira] [Commented] (FLINK-40417) Add remaining basic functionality to DataFrame API Dian Fu (Jira)
• 2026/08/20 [jira] [Assigned] (FLINK-40417) Add remaining basic functionality to DataFrame API Dian Fu (Jira)
• 2026/08/20 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/08/20 Re: [PR] [runtime] send Kafka tombstones on state pruning for durable log compaction [flink-agents] via GitHub
• 2026/08/20 Re: [PR] [integrations][java][python] Apply Anthropic native structured output [flink-agents] via GitHub
• 2026/08/20 Re: [PR] [integrations][java][python] Apply Anthropic native structured output [flink-agents] via GitHub

• Earlier messages
• Later messages