Messages by Thread
-
-
[jira] [Updated] (FLINK-41031) Close operator-owned resources on shutdown and exit on startup failure
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Resolved] (FLINK-41022) Update lz4-java to 1.12.0
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException)
Saurabh Kanawade (Jira)
-
Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc]
via GitHub
-
[PR] [hotfix] [docs] fix links version errors. hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink]
via GitHub
-
Re: [PR] [hotfix] [docs] fix links version errors. hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink]
via GitHub
-
Re: [PR] [hotfix] [docs] fix links version errors. hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink]
via GitHub
-
Re: [PR] [hotfix] [docs] fix links version errors. hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink]
via GitHub
-
Re: [PR] [hotfix] [docs] fix links version errors. hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink]
via GitHub
-
Re: [PR] [hotfix] [docs] fix links version errors. hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink]
via GitHub
-
[jira] [Updated] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty
ASF GitHub Bot (Jira)
-
[PR] [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas [flink]
via GitHub
-
[jira] [Updated] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40961) Support NOTIFY_STATEFUL_SETS
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40961][table] Support notifying stateful sets for broadcast tables in PTFs [flink]
via GitHub
-
Re: [PR] [FLINK-40829][python] Allow assign uid for Timestamp operators [flink]
via GitHub
-
[jira] [Created] (FLINK-41031) Close operator-owned executors and metric reporters on operator shutdown
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Resolved] (FLINK-40033) Modernize web-dashboard visualization libraries
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-41029) Close operator-owned executors and metric reporters on operator shutdown
Dennis-Mircea Ciupitu (Jira)
-
Re: [I] [Doc] Improve Setup and the Quickstart user journey [flink-agents]
via GitHub
-
Re: [PR] Bump @angular/core, @angular/animations, @angular/common, @angular/forms, @angular/platform-browser, @angular/platform-browser-dynamic, @angular/router, ng-zorro-antd and @angular/build in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] Bump @angular/core, @angular/animations, @angular/common, @angular/forms, @angular/platform-browser, @angular/platform-browser-dynamic, @angular/router, ng-zorro-antd and @angular/build in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] Bump @angular/core, @angular/animations, @angular/common, @angular/forms, @angular/platform-browser, @angular/platform-browser-dynamic, @angular/router, ng-zorro-antd and @angular/build in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [I] [Doc] Improve Model Routing examples and behavior reference [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-40046) Upgrade @antv/g2 to v5
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-24908) Improve SQL Error description for SQL Client
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-24908) Improve SQL Error description for SQL Client
Martijn Visser (Jira)
-
Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink]
via GitHub
-
[jira] [Commented] (FLINK-32593) DelimitedInputFormat will cause record loss for multi-bytes delimit when a delimit is seperated to two splits
Zhe Wang (Jira)
-
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
-
[jira] [Comment Edited] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-41009][connector/pulsar] Use a single transaction per checkpoint [flink-connector-pulsar]
via GitHub
-
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
-
[jira] [Updated] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT
ASF GitHub Bot (Jira)
-
[PR] [FLINK-41026][format/avro] Convert timestamps above precision 3 as microseconds in both directions [flink]
via GitHub
-
[PR] [FLINK-41028] Support data lake table properties in the Fluss pipeline sink [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink]
via GitHub
-
Re: [PR] Bump at.yawk.lz4:lz4-java from 1.10.3 to 1.11.1 [flink]
via GitHub
-
[PR] [FLINK-41025][kubernetes] Add config option to control enableServiceLinks of JobManager and TaskManager pods. [flink]
via GitHub
-
[jira] [Commented] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink]
via GitHub
-
[jira] [Created] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink
Hongshun Wang (Jira)
-
[jira] [Updated] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink
Hongshun Wang (Jira)
-
[jira] [Assigned] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink
Hongshun Wang (Jira)
-
Re: [I] [Feature] Support decision models in Flink Agents [flink-agents]
via GitHub
-
[PR] [FLINK-40807][table] Add XML_STRING function [flink]
via GitHub
-
[jira] [Updated] (FLINK-40807) Add XML_STRING() function
ASF GitHub Bot (Jira)
-
[PR] [hotfix][integrations][python][docs] Align vector stores with their declared contracts [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-41021) Update commons-beanutils to 1.11.0 and jsoup to 1.23.2
Martijn Visser (Jira)
-
Re: [I] [Feature] Support MCP tools and prompts runtime discovery [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT
Pritam Kumar (Jira)
-
Re: [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink]
via GitHub
-
[I] [Bug][runtime][java][python] Model-driven subagent await failures leave pending handles and fail the action [flink-agents]
via GitHub
-
Re: [I] [Doc] Improve Chat Models and built-in provider documentation [flink-agents]
via GitHub
-
Re: [PR] [docs] Consolidate resource guidance and improve Calling LLMs documentation [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-41025) Add config option to control enableServiceLinks of JobManager and TaskManager pods
ASF GitHub Bot (Jira)
-
Re: [PR] [api][java][python] Render a flat RowTypeInfo output schema as JSON Schema in the ReAct Agent prompt [flink-agents]
via GitHub
-
Re: [PR] [docs] Restructure the observability chapter [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-41025) Add config option to control enableServiceLinks of JobManager and TaskManager pods
Guotao Ding (Jira)
-
Re: [PR] Bump at.yawk.lz4:lz4-java from 1.10.3 to 1.11.4 [flink]
via GitHub
-
[PR] [hotfix][docs][api] Correct Calling LLMs, Vector Search and ReAct Agent to match the code [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-41024) Upgrade PyFlink docs to Sphinx 9.1
Martijn Visser (Jira)
-
Re: [PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-filesystems/flink-fs-hadoop-shaded [flink]
via GitHub
-
Re: [PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-table/flink-sql-client [flink]
via GitHub
-
Re: [PR] Bump org.jsoup:jsoup from 1.15.3 to 1.23.1 in /flink-docs [flink]
via GitHub
-
[jira] [Updated] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile
ASF GitHub Bot (Jira)
-
[PR] [FLINK-41023][python][docs] Build English and Chinese docs from one lockfile [flink]
via GitHub
-
[PR] [api][python][integrations] Share the native output model helper across chat model connections [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39788][kubernetes] Append .svc suffix to namespaced Kubernetes service hostnames [flink]
via GitHub
-
Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink]
via GitHub
-
Re: [PR] [FLINK-39219] [table] Support lineage extraction for DataStreamscan/sink providers [flink]
via GitHub
-
Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink]
via GitHub
-
Re: [I] [Bug] An output schema pydantic cannot render raises instead of taking the prompt fallback [flink-agents]
via GitHub
-
Re: [PR] [python][integrations] Raise a clear error for an unrenderable output schema in the Ollama connection [flink-agents]
via GitHub
-
Re: [PR] [integrations][java][python] Skip native structured output for a Map, JsonNode or dict field [flink-agents]
via GitHub