Messages by Date
-
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
-
2026/08/20
Re: [PR] [infra] Add a dist and dependency review guide [flink-agents]
via GitHub
-
2026/08/20
Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents]
via GitHub
-
2026/08/20
Re: [I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents]
via GitHub
-
2026/08/20
Re: [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents]
via GitHub
-
2026/08/20
Re: [I] [Bug] Tool parameter schema maps long/float (and all other non-int/double numerics) to "object" [flink-agents]
via GitHub
-
2026/08/20
Re: [PR] [plan] Map long/float and other numeric tool parameters to proper JSON Schema types [flink-agents]
via GitHub
-
2026/08/20
[jira] [Updated] (FLINK-40397) Add binlog position lag metrics for MySQL binlog reader
wangkang (Jira)
-
2026/08/20
[jira] [Updated] (FLINK-40397) Add binlog position lag metrics for MySQL binlog reader
wangkang (Jira)
-
2026/08/20
[jira] [Updated] (FLINK-40397) Add binlog position lag metrics for MySQL binlog reader
wangkang (Jira)
-
2026/08/20
Re: [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader [flink-cdc]
via GitHub
-
2026/08/20
Re: [I] [Tech Debt] Documentation index page has an empty column, a stale sync link, and unversioned Hugo build instructions [flink-agents]
via GitHub
-
2026/08/20
Re: [PR] [docs] Improve the documentation index page and build instructions [flink-agents]
via GitHub
-
2026/08/20
Re: [PR] [docs] Document preview status and security risks [flink-agents]
via GitHub
-
2026/08/20
[jira] [Resolved] (FLINK-40340) UnsupportedOperationException for MySQL ZEROFILL types without UNSIGNED
Yanquan Lv (Jira)
-
2026/08/20
Re: [PR] [FLINK-40340] Fix schema change exception when parsing MySQL zerofill data types without unsigned keyword [flink-cdc]
via GitHub
-
2026/08/20
[PR] [FLINK-40416][runtime] Add built-in text AI functions [flink-cdc]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-39321][pipeline-connector-paimon]Fixes a bug where Flink CDC fails to write to Paimon dynamic bucket tables when dynamic-bucket.initial-buckets=1 and Flink parallelism > 1. [flink-cdc]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/20
[jira] [Commented] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices
Herbert Wang (Jira)
-
2026/08/20
[jira] [Updated] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices
Herbert Wang (Jira)
-
2026/08/20
Re: [PR] [FLINK-40243] Bump JDBC test dependencies: derby 10.15.2.0→10.17.1.0, postgresql 42.5.6→42.7.13 [flink-kubernetes-operator]
via GitHub
-
2026/08/20
Re: [PR] [hotfix] Guard Optional.get() in Kafka and StarRocks connector schema lookups [flink-cdc]
via GitHub
-
2026/08/20
[PR] Add integration test for autoscaler Kafka/Pulsar partition detection [flink-kubernetes-operator]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state [flink]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40379][runtime] Wait for pre-restart parallelism to become available again after a rescale-triggered restart [flink]
via GitHub
-
2026/08/20
[jira] [Created] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint
Rui Fan (Jira)
-
2026/08/20
[jira] [Commented] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
-
2026/08/20
Re: [PR] [FLINK-40037][tests] Local RocksDB working directory leaked (with all… [flink]
via GitHub
-
2026/08/20
[jira] [Commented] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices
Zhe Wang (Jira)
-
2026/08/20
[PR] [FLINK-40447][table] Fall back to retract when input upsert key is empty or mixed [flink]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40447][table] Fall back to retract when input upsert key is empty or mixed [flink]
via GitHub
-
2026/08/20
[jira] [Updated] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed
ASF GitHub Bot (Jira)
-
2026/08/20
[jira] [Commented] (FLINK-40450) Planner tests miss direct flink-table-code-splitter test dependency
Shekhar Prasad Rajak (Jira)
-
2026/08/20
[jira] [Created] (FLINK-40450) Planner tests miss direct flink-table-code-splitter test dependency
Shekhar Prasad Rajak (Jira)
-
2026/08/20
Re: [PR] [FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion [flink-kubernetes-operator]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
-
2026/08/20
[PR] [FLINK-40448] Pin resolved address during operator artifact fetch to prevent DNS rebinding [flink-kubernetes-operator]
via GitHub
-
2026/08/20
[jira] [Closed] (FLINK-40390) Validate JSON_LENGTH path prefixes at plan time and reuse the shared JSON codegen
Gustavo de Morais (Jira)
-
2026/08/20
Re: [PR] [FLINK-40390][table] Optimised JSON_LENGTH codegen [flink]
via GitHub
-
2026/08/20
[jira] [Updated] (FLINK-40448) Pin resolved address during operator artifact fetch to prevent DNS rebinding
ASF GitHub Bot (Jira)
-
2026/08/20
Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion [flink-kubernetes-operator]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-39986][table-planner][python] Support full-tree CSE and condition-projection deduplication for Python UDFs [flink]
via GitHub
-
2026/08/20
[jira] [Closed] (FLINK-40443) Harden autoscaler metrics name parsing against complex regex
Gyula Fora (Jira)
-
2026/08/20
[jira] [Created] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission
Martijn Visser (Jira)
-
2026/08/20
Re: [PR] [FLINK-40443] Harden autoscaler metrics name parsing against complex regex [flink-kubernetes-operator]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state [flink]
via GitHub
-
2026/08/20
[jira] [Created] (FLINK-40448) Pin resolved address during operator artifact fetch to prevent DNS rebinding
Purushottam Sinha (Jira)
-
2026/08/20
Re: [PR] [FLINK-40379][runtime] Wait for pre-restart parallelism to become available again after a rescale-triggered restart [flink]
via GitHub
-
2026/08/20
Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents]
via GitHub
-
2026/08/20
[jira] [Updated] (FLINK-40379) AdaptiveScheduler is in restart loop when task cancellation consistently times out
ASF GitHub Bot (Jira)
-
2026/08/20
[PR] [FLINK-40379][runtime] Wait for pre-restart parallelism to become available again after a rescale-triggered restart [flink]
via GitHub
-
2026/08/20
[PR] [FLINK-39986][table-planner][python] Support full-tree CSE and condition-projection deduplication for Python UDFs [flink]
via GitHub
-
2026/08/20
[jira] [Created] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed
Gustavo de Morais (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-40443] Harden autoscaler metrics name parsing against complex regex [flink-kubernetes-operator]
via GitHub
-
2026/08/20
[jira] [Updated] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint
ASF GitHub Bot (Jira)
-
2026/08/20
[PR] [FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state [flink]
via GitHub
-
2026/08/20
[jira] [Resolved] (FLINK-38544) FLIP-547 V2: Filtering record before processing with spilling strategy
Rui Fan (Jira)
-
2026/08/20
[jira] [Commented] (FLINK-40417) Add remaining basic functionality to DataFrame API
Liu Liu (Jira)
-
2026/08/20
Re: [PR] [FLINK-40443] Harden autoscaler metrics name parsing against complex regex [flink-kubernetes-operator]
via GitHub
-
2026/08/20
Re: [PR] [Connectors / Opensearch] [FLINK-40189] security vunerability fix in IndexGeneratorFactory.java [flink-connector-opensearch]
via GitHub
-
2026/08/20
[jira] [Commented] (FLINK-40189) Found Security Vunerability in IndexGeneratorFactory.java
Taranpreet Kaur (Jira)
-
2026/08/20
[jira] [Commented] (FLINK-40189) Found Security Vunerability in IndexGeneratorFactory.java
Martijn Visser (Jira)
-
2026/08/20
Re: [PR] [FLINK-37908][Connectors/Kinesis] Self-heal EFO consumer on restart races and external deletion [flink-connector-aws]
via GitHub
-
2026/08/20
Re: [PR] [FLINK-37908][Connectors/Kinesis] Self-heal EFO consumer on restart races and external deletion [flink-connector-aws]
via GitHub