issues  

Messages by Date

• 2026/10/15 [jira] [Updated] (FLINK-40963) Add support for DATE and TIME conversion to JSON ASF GitHub Bot (Jira)
• 2026/10/15 [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] via GitHub
• 2026/10/15 [jira] [Created] (FLINK-41004) Column expansion does not work with REQUIRE_ON_TIME trait Timo Walther (Jira)
• 2026/10/15 Re: [PR] [FLINK-40962][table-planner] expose LEAD(TIMESTAMP_LTZ)/LAG(TIMESTAMP_LTZ) in batch mode [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-40962) LEAD() and LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode Saketh Kurnool (Jira)
• 2026/10/15 [jira] [Updated] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode ASF GitHub Bot (Jira)
• 2026/10/15 [PR] Rebased fix [flink-cdc] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink ASF GitHub Bot (Jira)
• 2026/10/15 [PR] [FLINK-41009][connector/pulsar] Use a single transaction per checkpoint [flink-connector-pulsar] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Yubiao Feng (Jira)
• 2026/10/15 Re: [PR] [docs] Clarify Tool Use injection and parallel-call guidance [flink-agents] via GitHub
• 2026/10/15 [jira] [Created] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Yubiao Feng (Jira)
• 2026/10/15 [jira] [Updated] (FLINK-41006) upgrade starrocks connector to 1.2.16 ASF GitHub Bot (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41006) upgrade starrocks connector to 1.2.16 peiyu (Jira)
• 2026/10/15 [jira] [Updated] (FLINK-40924) table.exec.sink.upsert-materialize=FORCE silently bypasses the require-on-conflict check sepuri sai krishna (Jira)
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check ASF GitHub Bot (Jira)
• 2026/10/15 [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40436][python] Add UDAF support to the DataFrame API [flink] via GitHub
• 2026/10/15 [jira] [Commented] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
• 2026/10/15 Re: [PR] [FLINK-40996][table] Make `TRY_PARSE_JSON`, `PARSE_JSON` reuse parsed json [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 [jira] [Created] (FLINK-41005) MiniCluster should clean up partially started services when start() fails Dale Lane (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41003) Bump Pulsar version to 4.0.14 Ferenc Csaky (Jira)
• 2026/10/15 [jira] [Resolved] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Robert Metzger (Jira)
• 2026/10/15 [jira] [Updated] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Robert Metzger (Jira)
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 [jira] [Commented] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Dian Fu (Jira)
• 2026/10/15 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/15 [jira] [Commented] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Dian Fu (Jira)
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 [jira] [Closed] (FLINK-41001) OpenAI model provider rejects compatible string input types Dian Fu (Jira)
• 2026/10/15 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/15 Re: [PR] [docs] Clarify Tool Use injection and parallel-call guidance [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/15 Re: [PR] [docs] Clarify Tool Use injection and parallel-call guidance [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• 2026/10/15 Re: [PR] [hotfix][core] Use the try mechanism to proactively close closeable objects to avoid object leaks in ExceptionUtils#stringifyException [flink] via GitHub
• 2026/10/15 Re: [PR] [docs] Clarify Tool Use injection and parallel-call guidance [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [integrations][java] List each enum constant by its Jackson-serialized value in native schemas [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [hotfix][core] Use the try mechanism to proactively close closeable objects to avoid object leaks in ExceptionUtils#stringifyException [flink] via GitHub
• 2026/10/15 [PR] [hotfix][core] Use the try mechanism to proactively close closeable objects to avoid object leaks in ExceptionUtils#stringifyException [flink] via GitHub
• 2026/10/15 [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40436][python] Add UDAF support to the DataFrame API [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-41003) Bump Pulsar version to 4.0.14 ASF GitHub Bot (Jira)
• 2026/10/15 [PR] [FLINK-41003] Bump Pulsar version to 4.0.14 [flink-connector-pulsar] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 [PR] [api][java][python] Add DecisionModel resources and Event/Action calls [flink-agents] via GitHub
• 2026/10/15 [jira] [Comment Edited] (FLINK-40959) Batch sort can emit unsorted rows if comparator implementation is long enough to be split Ferenc Csaky (Jira)
• 2026/10/15 Re: [PR] [BP-1.20][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsorted rows [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40973][pipeline-connector/fluss] Retry transient periodic discovery failures [flink-cdc] via GitHub
• 2026/10/15 Re: [PR] [docs] Improve Agent core concepts, Actions, and Events guides [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [docs] Improve Built-in ReAct Agent usage documentation [flink-agents] via GitHub
• 2026/10/15 [PR] [docs] Improve Agent core concepts, Actions, and Events guides [flink-agents] via GitHub
• 2026/10/15 [jira] [Created] (FLINK-41002) Move test-only defaults out of MiniClusterConfiguration Dale Lane (Jira)
• 2026/10/15 [jira] [Resolved] (FLINK-40294) Instrument async scalar and table UDF calls with metrics Yuepeng Pan (Jira)
• 2026/10/15 [jira] [Commented] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Sangkyoon Nam (Jira)
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40001][table] Upgrade Calcite version to 1.42.0 [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40298][table] Opt-in name-based state schema evolution for RowData [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-40294) Instrument async scalar and table UDF calls with metrics Yuepeng Pan (Jira)
• 2026/10/15 Re: [PR] [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism [flink] via GitHub
• 2026/10/15 Re: [I] [Tech Debt][Observability] Replace Event Log with a Unified Trace Log [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [docs] Improve Built-in ReAct Agent usage documentation [flink-agents] via GitHub
• 2026/10/15 [jira] [Resolved] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history Martijn Visser (Jira)
• 2026/10/15 Re: [PR] [api][runtime][python] Replace Event Log with unified Trace Log [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40440][python] Add model prediction support to the DataFrame API [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-40998) Web dashboard: Update dependencies with open Dependabot advisories ASF GitHub Bot (Jira)
• 2026/10/15 [jira] [Closed] (FLINK-40440) Add LLM prediction support to DataFrame API Dian Fu (Jira)
• 2026/10/15 [jira] [Comment Edited] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation abjfh (Jira)
• 2026/10/15 [jira] [Comment Edited] (FLINK-38774) Filesystem connector: "incomplete partition spec" when partition discovery descends into hidden directories abjfh (Jira)
• 2026/10/15 [jira] [Comment Edited] (FLINK-38774) Filesystem connector: "incomplete partition spec" when partition discovery descends into hidden directories abjfh (Jira)
• 2026/10/15 [jira] [Comment Edited] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation abjfh (Jira)
• 2026/10/15 [jira] [Comment Edited] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation abjfh (Jira)
• 2026/10/15 [jira] [Commented] (FLINK-38774) Filesystem connector: "incomplete partition spec" when partition discovery descends into hidden directories abjfh (Jira)
• 2026/10/15 Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
• 2026/10/15 [jira] [Commented] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation abjfh (Jira)
• 2026/10/15 [jira] [Resolved] (FLINK-40808) Setting up PyPI for AWS Connector Samrat Deb (Jira)
• 2026/10/15 Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/15 [PR] [docs] Clarify Tool Use injection and parallel-call guidance [flink-agents] via GitHub
• 2026/10/15 Re: [I] [Bug][integrations][java] A Map field in a native schema becomes an empty object on OpenAI, Azure OpenAI and Anthropic [flink-agents] via GitHub
• 2026/10/15 [jira] [Commented] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Biao Geng (Jira)
• 2026/10/15 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40996][table] Make `TRY_PARSE_JSON`, `PARSE_JSON` reuse parsed json [flink] via GitHub
• 2026/10/15 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/10/15 Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation abjfh (Jira)
• 2026/10/15 [jira] [Updated] (FLINK-38774) Filesystem connector: "incomplete partition spec" when partition discovery descends into hidden directories abjfh (Jira)
• 2026/10/15 Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40996][table] Make `TRY_PARSE_JSON`, `PARSE_JSON` reuse parsed json [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/15 [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation huyuliang (Jira)
• 2026/10/15 Re: [PR] [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607) [flink] via GitHub
• 2026/10/15 [jira] [Updated] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation huyuliang (Jira)
• 2026/10/15 Re: [PR] [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607) [flink] via GitHub
• 2026/10/15 [PR] [integrations][java] List each enum constant by its Jackson-serialized value in native schemas [flink-agents] via GitHub
• 2026/10/15 [jira] [Comment Edited] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Biao Geng (Jira)
• 2026/10/15 [jira] [Closed] (FLINK-40806) Add PARSE_XML() and TRY_PARSE_XML() functions Timo Walther (Jira)
• 2026/10/15 [PR] [docs] Improve Built-in ReAct Agent usage documentation [flink-agents] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/15 Re: [PR] [BP-1.20][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsorted rows [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/15 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/15 Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
• 2026/10/15 [PR] [BP-1.20][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsorted rows [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-34620][formats][protobuf] Add serialize-side handling for recursive message schemas [flink] via GitHub
• 2026/10/14 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40996][table] Make `TRY_PARSE_JSON`, `PARSE_JSON` reuse parsed json [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-41001][model] Accept compatible string inputs in the OpenAI provider [flink] via GitHub
• 2026/10/14 Re: [I] [Tech Debt][API][Chat Model] Review the chat model invocation flow in custom Actions [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-34620][formats][protobuf] Add serialize-side handling for recursive message schemas [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [api][runtime][python] Replace Event Log with unified Trace Log [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40440][python] Add model prediction support to the DataFrame API [flink] via GitHub
• 2026/10/14 [jira] [Commented] (FLINK-8277) Optimize code generation by using local references huyuliang (Jira)
• 2026/10/14 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/14 [jira] [Updated] (FLINK-41001) OpenAI model provider rejects compatible string input types ASF GitHub Bot (Jira)
• 2026/10/14 [PR] [FLINK-41001][model] Accept compatible string inputs in the OpenAI provider [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40440][python] Add model prediction support to the DataFrame API [flink] via GitHub
• 2026/10/14 [jira] [Created] (FLINK-41001) OpenAI model provider rejects compatible string input types Liu Liu (Jira)
• 2026/10/14 [jira] [Updated] (FLINK-41001) OpenAI model provider rejects compatible string input types Liu Liu (Jira)
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 [jira] [Closed] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Yanquan Lv (Jira)
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 [jira] [Commented] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Sangkyoon Nam (Jira)
• 2026/10/14 Re: [PR] [FLINK-40983][docs][pipeline-connector/kafka] Document sink.delivery-guarantee [flink-cdc] via GitHub
• 2026/10/14 [jira] [Commented] (FLINK-40889) NDU plan visitor has no branch for VECTOR_SEARCH, TRY_RESOLVE and EXPLAIN PLAN_ADVICE fail ChenZhuo (Jira)
• 2026/10/14 [jira] [Resolved] (FLINK-40994) Upgrade paimon to 2.1.0 Yanquan Lv (Jira)
• 2026/10/14 Re: [PR] [FLINK-40994][connect/paimon] Upgrade Paimon SDK to 2.1.0 [flink-cdc] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40998][runtime-web] Update web-dashboard dependencies with open Dependabot advisories [flink] via GitHub
• 2026/10/14 [jira] [Comment Edited] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Dian Fu (Jira)
• 2026/10/14 [jira] [Commented] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Dian Fu (Jira)
• 2026/10/14 [jira] [Comment Edited] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Dian Fu (Jira)
• 2026/10/14 [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Zakelly Lan (Jira)
• 2026/10/14 Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
• 2026/10/14 [PR] [FLINK-38413] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] via GitHub
• 2026/10/14 Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink] via GitHub
• 2026/10/14 [jira] [Commented] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API Liu Liu (Jira)
• 2026/10/14 [jira] [Commented] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API ChenZhuo (Jira)
• 2026/10/14 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/14 Re: [I] [Doc] Improve Built-in ReAct Agent usage documentation [flink-agents] via GitHub
• 2026/10/14 [jira] [Closed] (FLINK-40433) Add map and map_batches support to DataFrame API Dian Fu (Jira)
• 2026/10/14 Re: [PR] [FLINK-40440][python] Add model prediction support to the DataFrame API [flink] via GitHub
• 2026/10/14 [jira] [Created] (FLINK-41000) Pulsar 5.0 support Hongbo Miao (Jira)
• 2026/10/14 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/10/14 Re: [I] [Bug][integrations][java] An enum with @JsonProperty on only some constants lists Java names in native schemas [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40938][Connectors/DynamoDB] Support AT_TIMESTAMP initial position in DynamoDB Streams source [flink-connector-aws] via GitHub
• 2026/10/14 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40676] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40002][table] Keep metadata column references out of physical filter push-down [flink] via GitHub
• 2026/10/14 Re: [I] [Bug][integrations][java] An enum with @JsonProperty on only some constants lists Java names in native schemas [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
• 2026/10/14 [jira] [Created] (FLINK-40999) [cdc-composer] Factory JAR path resolution fails with "URI is not hierarchical" for relative usrlib paths in application mode wind.wang (Jira)
• 2026/10/14 Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [doc] Add a structured output user guide [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40997][table-planner] Fix join upsert key order being indeterministic [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
• 2026/10/14 [PR] [FLINK-40998][runtime-web] Update web-dashboard dependencies with open Dependabot advisories [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
• 2026/10/14 [jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys ASF GitHub Bot (Jira)
• 2026/10/14 Re: [PR] [FLINK-40996][table] Make `TRY_PARSE_JSON`, `PARSE_JSON` reuse parsed json [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• 2026/10/14 [PR] [FLINK-40997][table-planner] Fix join upsert key order being undeterministic [flink] via GitHub
• 2026/10/14 Re: [PR] [doc] Add a structured output user guide [flink-agents] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• 2026/10/14 Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub

• Earlier messages
• Later messages