Messages by Thread
-
-
[PR] Bump fast-uri from 3.1.3 to 3.1.7 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE applies column-change rules inconsistently with ALTER ... AS and can silently reorder existing columns
Arvid Heise (Jira)
-
[jira] [Resolved] (FLINK-40537) IDEA should load project with java from source.java.version
Sergey Nuyanzin (Jira)
-
Re: [I] [Bug] Long-term memory operations read the partition key from shared mutable state on the async worker thread [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery
Rui Fan (Jira)
-
[jira] [Resolved] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock
Rui Fan (Jira)
-
[jira] [Assigned] (FLINK-40421) Add sorting support in DataFrame API
Dian Fu (Jira)
-
[jira] [Updated] (FLINK-40540) Put the rule's reason first in the planner's "Cannot generate a valid execution plan" message
ASF GitHub Bot (Jira)
-
[PR] [e2e][java] Temporarily disable Mem0 cross-language test [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled
Rui Fan (Jira)
-
[jira] [Resolved] (FLINK-40513) Introduce multimodal AI functions for image understanding
Xiqian Yu (Jira)
-
[jira] [Created] (FLINK-40541) LATERAL SNAPSHOT join rejects a valid build-side watermark when it is declared on a column hidden by the column-expansion strategy
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-37926) Support type casting between variant and constructed type
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37926][table] Support casting from VARIANT to ARRAY [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel
Rui Fan (Jira)
-
[PR] [FLINK-40540][table-planner] Put the rule's reason first in the planning error [flink]
via GitHub
-
[I] [Bug][runtime] Interrupted tool calls are recorded as tool errors, letting the action loop continue and persist as completed [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-40431) Add UDF support to DataFrame API
Dian Fu (Jira)
-
[jira] [Resolved] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery
Rui Fan (Jira)
-
[jira] [Resolved] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string
Rui Fan (Jira)
-
[jira] [Created] (FLINK-40540) Put the rule's reason first in the planner's "Cannot generate a valid execution plan" message
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40539) Redact sensitive values in SET; and session config responses
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-40539) Redact sensitive values in SET; and session config responses
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked
Rui Fan (Jira)
-
[jira] [Commented] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory
Zhe Wang (Jira)
-
[I] [Bug] Cross-language Mem0 add crashes the JVM in Pemja on JDK 21 [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-40537) IDEA should load project with java from source.java.version
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40424) Add windowing TVF support to DataFrame API
ASF GitHub Bot (Jira)
-
[jira] [Closed] (FLINK-40422) Add slicing APIs to DataFrame API
Dian Fu (Jira)
-
[jira] [Closed] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic
Jira
-
[jira] [Updated] (FLINK-40537) IDEA should load project with java from source.java.version
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40537][build] IDEA should use java version same as in `source.java.version` [flink]
via GitHub
-
[jira] [Created] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic
Jira
-
[jira] (FLINK-40421) Add sorting support in DataFrame API
Hirson Zhang (Jira)
-
[PR] Bump browserslist from 4.28.4 to 4.28.8 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+
Sergey Nuyanzin (Jira)
-
[I] [Tech Debt][API][Chat Model] Review the chat model invocation flow in custom Actions [flink-agents]
via GitHub
-
[I] [Tech Debt][API][Action] Improve annotation-based cross-language Action declarations [flink-agents]
via GitHub
-
[jira] [Comment Edited] (FLINK-40421) Add sorting support in DataFrame API
Hirson Zhang (Jira)
-
[I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40512) PostgreSQL yaml source is busy on inferring schema change event
Hongshun Wang (Jira)
-
[jira] [Updated] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40477][table] Fix constraint enforcer for partial deletes [flink]
via GitHub
-
Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive]
via GitHub
-
Re: [PR] [FLINK-39095][docs] Document EXPLAIN CHANGELOG_MODE for streaming queries [flink]
via GitHub
-
Re: [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink]
via GitHub
-
Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink]
via GitHub
-
Re: [I] [Tech Debt] Non-happy-path response handling diverges between Java and Python in OpenAI-family connections [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40536][build] Bump cyclonedx-maven-plugin to 2.9.3 [flink]
via GitHub
-
[jira] [Created] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-40423) Add Top-N support to DataFrame API
Dian Fu (Jira)
-
[jira] [Updated] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-40533] Upgrade supported Flink versions to 2.3 [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-40534) Memory tuning config overrides are computed before the ScalingExecutorPlugin chain and persisted unchanged when a plugin modifies the scaling decision
Shubhankar Sunil Unhale (Jira)
-
[jira] [Updated] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40535] Standalone session clusters are redeployed instead of scaled in-place [flink-kubernetes-operator]
via GitHub
-
[jira] [Created] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place
Dennis-Mircea Ciupitu (Jira)
-
[PR] [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding [flink-cdc]
via GitHub
-
[PR] [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale [flink]
via GitHub
-
[PR] [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain [flink]
via GitHub
-
[jira] [Updated] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink]
via GitHub
-
[jira] [Updated] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain
Rui Fan (Jira)
-
[jira] [Created] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled
VISHAL B (Jira)
-
[jira] [Commented] (FLINK-40423) Add Top-N support to DataFrame API
Timo Theusner (Jira)
-
[jira] [Resolved] (FLINK-40507) upgrade paimon to 2.0.0
Xiqian Yu (Jira)
-
[jira] [Created] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3
Xiqian Yu (Jira)
-
[PR] [hotfix][java][python] Harden Bash arithmetic evaluation [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job
Juliusz Nadberezny (Jira)
-
[I] [Feature] Introduce subagent framework and AGENT resource type [flink-agents]
via GitHub
-
[PR] FLINK-40531 Serialize parallelism overrides in a version-portable format [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE applies column-change rules inconsistently with ALTER ... AS and can silently reorder existing columns
Arvid Heise (Jira)
-
[jira] [Updated] (FLINK-40513) Introduce multimodal AI functions for image understanding
Mao Jiayi (Jira)
-
[jira] [Reopened] (FLINK-40513) Introduce multimodal AI functions for image understanding
Mao Jiayi (Jira)
-
[jira] [Closed] (FLINK-40486) Introduce the UUID logical type
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job
ASF GitHub Bot (Jira)
-
[jira] [Resolved] (FLINK-40416) Add built-in text AI functions to Pipeline transforms
Xiqian Yu (Jira)
-
[jira] [Closed] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator
dylanhz (Jira)
-
[jira] [Commented] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator
dylanhz (Jira)
-
Re: [PR] [FLINK-37094][hive] Adapt Hive connector to Flink 2.0 API changes [flink-connector-hive]
via GitHub
-
[jira] [Commented] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager
Taranpreet Kaur (Jira)
-
[jira] [Assigned] (FLINK-40017) Introduce Seaweedfs in native-s3-fs
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-40017) Introduce Seaweedfs in native-s3-fs
Samrat Deb (Jira)
-
[jira] [Closed] (FLINK-40017) Introduce Seaweedfs in native-s3-fs
Samrat Deb (Jira)
-
Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink]
via GitHub
-
[PR] [tools][ci] Fix the bats suite's boundary with the scripts it tests [flink-agents]
via GitHub
-
[PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink]
via GitHub
-
[jira] [Updated] (FLINK-40530) HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-40530) HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response
Archit Goyal (Jira)
-
[jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink]
via GitHub
-
[jira] [Created] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use
Deepyaman Datta (Jira)
-
[I] [Tech Debt][API][Flink Integration] Simplify Agent output materialization to DataStream and Table [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-40421) Add sorting support in DataFrame API
Hirson Zhang (Jira)
-
[jira] [Assigned] (FLINK-40424) Add windowing TVF support to DataFrame API
Dian Fu (Jira)
-
[jira] [Updated] (FLINK-40528) Codegen should be tolerate to partial deletes
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink]
via GitHub
-
[jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-40527) Update flink-shaded to 22.0
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40527] Update flink-shaded to 22.0 [flink]
via GitHub
-
[jira] [Created] (FLINK-40527) Update flink-shaded to 22.0
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40510) Use Apache Parent POM 39
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40510) Use Apache Parent POM 39
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation
Rango (Jira)
-
[PR] [FLINK-39570] Bump Netty to 4.1.136.Final (release-20.0) [flink-shaded]
via GitHub
-
[jira] [Updated] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER()
ASF GitHub Bot (Jira)
-
[jira] [Closed] (FLINK-40356) Add MAP_FROM_ENTRIES function
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-39813) [Connectors/Kinesis] Add lineage support to Kinesis Streams connector
ASF GitHub Bot (Jira)