Messages by Thread
-
[jira] [Assigned] (FLINK-41253) Python scalar UDFs produce incorrectly ordered columns when mixing sync and async calls
Dian Fu (Jira) via issues
-
[jira] [Created] (FLINK-41444) Upgrade Cassandra Java Driver to 4.x version
Madhavan (Jira) via issues
-
Re: [PR] [FLINK-40040][cdc-runtime] Wrap coordinator failure in SerializedThrowable across the RPC boundary [flink-cdc]
github-actions[bot] (via GitHub) via issues
-
[PR] [hotfix][build] Bump maven-jar-plugin version to 3.5.1 from 2.4 [flink]
snuyanzin (via GitHub) via issues
-
Re: [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc]
MartijnVisser (via GitHub) via issues
-
Re: [PR] [FLINK-34923][python] Support nested rows in Table.to_pandas [flink]
1fanwang (via GitHub) via issues
-
[jira] [Updated] (FLINK-41443) Inner lookup join keeps a stale row when an update moves the join key to a row the lookup table doesn't have
Anton Borisov (Jira) via issues
-
[PR] BP-1.20[[FLINK-41425][ci] Drop Azure cron build which requires Microsoft machines from nightly <!-- [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Commented] (FLINK-41443) Inner lookup join keeps a stale row when an update moves the join key to a row the lookup table doesn't have
Anton Borisov (Jira) via issues
-
[PR] [FLINK-41425][ci] Drop Azure cron build which requires Microsoft mach… [flink]
snuyanzin (via GitHub) via issues
-
[PR] [BP-2.4][FLINK-41425][ci] Drop Azure cron build which requires Microsoft machines from nightly [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41443) Inner lookup join keeps a stale row when an update moves the join key to a row the lookup table doesn't have
Anton Borisov (Jira) via issues
-
[jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier
Martijn Visser (Jira) via issues
-
[PR] [FLINK-41212][table-planner] Improve FULL refresh mode error messages [flink]
Timm0 (via GitHub) via issues
-
Re: [PR] [FLINK-40279][connector-http] Add HTTP sink OIDC, proxy and HTTP version options [flink-connector-http]
davidradl (via GitHub) via issues
-
Re: [PR] [FLINK-41192][connector-http] Fail the HTTP sink request when a retry attempt throws [flink-connector-http]
davidradl (via GitHub) via issues
-
[jira] [Created] (FLINK-41442) Unaligned checkpoint trigger overtakes queued AddSplitEvent, splits lost on restore
Kaivalya Apte (Jira) via issues
-
[jira] [Created] (FLINK-41441) Operator silently runs on the JDK HTTP client instead of OkHttp
Dennis-Mircea Ciupitu (Jira) via issues
-
Re: [PR] [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (release-2.4) [flink]
1996fanrui (via GitHub) via issues
-
Re: [PR] [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (release-2.3) [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out
Rui Fan (Jira) via issues
-
Re: [PR] [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (release-1.20) [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods
Rui Fan (Jira) via issues
-
[jira] [Assigned] (FLINK-40445) Autoscaler: integration test for Kafka/Pulsar source partition-metric detection
Robert Metzger (Jira) via issues
-
[jira] [Resolved] (FLINK-40445) Autoscaler: integration test for Kafka/Pulsar source partition-metric detection
Robert Metzger (Jira) via issues
-
[PR] [FLINK-41439][table] Limit the length of the result of XML_STRING [flink]
manner (via GitHub) via issues
-
[PR] [FLINK-41438][table-planner] Return NULL for missing ARRAY, MAP and ROW elements of a NOT NULL type [flink]
raminqaf (via GitHub) via issues
-
[jira] [Commented] (FLINK-41432) Invalid value for materialized-table.default-start-mode fails with MissingFormatArgumentException
Sergey Nuyanzin (Jira) via issues
-
[jira] [Created] (FLINK-41440) Invalid InputProperty for various StreamExecNodes
Timo Walther (Jira) via issues
-
[jira] [Updated] (FLINK-41440) Invalid InputProperty for various StreamExecNodes
Timo Walther (Jira) via issues
-
[jira] [Assigned] (FLINK-41432) Invalid value for materialized-table.default-start-mode fails with MissingFormatArgumentException
Sergey Nuyanzin (Jira) via issues
-
[jira] [Resolved] (FLINK-41432) Invalid value for materialized-table.default-start-mode fails with MissingFormatArgumentException
Sergey Nuyanzin (Jira) via issues
-
[jira] [Assigned] (FLINK-41367) JDBC: Test SQL Server dialect on SQL Server 2025, not retired Azure SQL Edge; cover XA
Martijn Visser (Jira) via issues
-
[jira] [Commented] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode
Giannis Polyzos (Jira) via issues
-
[jira] [Updated] (FLINK-41438) ARRAY, MAP and ROW element access returns -1 instead of NULL when the element type is NOT NULL
ASF GitHub Bot (Jira) via issues
-
[PR] [BP-2.2][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink]
mateczagany (via GitHub) via issues
-
[PR] [BP-2.4][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink]
mateczagany (via GitHub) via issues
-
[jira] [Updated] (FLINK-41439) XML_STRING can run out of memory for a variant within the size limit
Moritz Manner (Jira) via issues
-
[jira] [Created] (FLINK-41439) XML_STRING can run out of memory for a variant within the size limit
Moritz Manner (Jira) via issues
-
[jira] [Created] (FLINK-41438) ARRAY, MAP and ROW element access returns -1 instead of NULL when the element type is NOT NULL
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-34656) Generated code for `ITEM` operator should return null when getting element of a null map/array/row
Ramin Gharib (Jira) via issues
-
Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink]
gaborgsomogyi (via GitHub) via issues
-
[jira] [Assigned] (FLINK-34656) Generated code for `ITEM` operator should return null when getting element of a null map/array/row
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41436) Planning time grows exponentially with the depth of nested catalog views because CatalogManager re-parses unresolved views on every lookup
Arvid Heise (Jira) via issues
-
[jira] [Updated] (FLINK-41212) Reject FULL refresh mode from a plain TableEnvironment
ASF GitHub Bot (Jira) via issues
-
[jira] [Commented] (FLINK-41273) Allow UNION, INTERSECT and EXCEPT on unbounded tables in the Table API
Gustavo de Morais (Jira) via issues
-
[jira] [Resolved] (FLINK-41271) PyFlink tasks remain RUNNING after a Beam data RPC failure
Dian Fu (Jira) via issues
-
[jira] [Assigned] (FLINK-38753) Enrich more upsert keys by equiv expressions
Gustavo de Morais (Jira) via issues
-
[jira] [Resolved] (FLINK-38753) Enrich more upsert keys by equiv expressions
Gustavo de Morais (Jira) via issues
-
[jira] [Commented] (FLINK-38753) Enrich more upsert keys by equiv expressions
Gustavo de Morais (Jira) via issues
-
[jira] [Updated] (FLINK-41436) Planning time grows exponentially with the depth of nested catalog views because CatalogManager re-parses unresolved views on every lookup
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41436][table] Reuse view resolutions while resolving nested views [flink]
AHeise (via GitHub) via issues
-
[PR] [Backport][FLINK-41371][table] Keep upsert mode for row-semantic PTFs [flink]
gustavodemorais (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE
Gustavo de Morais (Jira) via issues
-
Re: [PR] [FLINK-41101][jdbc] Roll back the prepared transactions that earlier jobs left behind [flink-connector-jdbc]
MartijnVisser (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input
Martijn Visser (Jira) via issues
-
Re: [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc]
MartijnVisser (via GitHub) via issues
-
[jira] [Created] (FLINK-41437) Wait until a cancelled materialized table refresh job has stopped
Timo Theusner (Jira) via issues
-
[PR] [api][integrations][java][python] Add DashScope media and rerank resources [flink-agents]
joeyutong (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-41271) PyFlink tasks remain RUNNING after a Beam data RPC failure
Dian Fu (Jira) via issues
-
[I] [Feature] Add media generation and reranking resources with DashScope providers [flink-agents]
joeyutong (via GitHub) via issues
-
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
twalthr (via GitHub) via issues
-
[PR] [hotfix][docs] Document the [BP-X.Y] prefix for backport PRs [flink]
spuru9 (via GitHub) via issues
-
[jira] [Updated] (FLINK-41435) SecurityUtils.install should be idempotent for equivalent security configurations
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-21995][yarn-tests] Whitelist netty-wrapped Pekko connection-refused WARN [flink]
1996fanrui (via GitHub) via issues
-
[PR] [FLINK-41435][runtime] Make SecurityUtils.install idempotent [flink]
lcx412 (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41371) Row-semantic PTFs force retract mode on upsert inputs
Gustavo de Morais (Jira) via issues
-
[jira] [Created] (FLINK-41435) SecurityUtils.install should be idempotent for equivalent security configurations
LuChengxiang (Jira) via issues
-
[jira] [Commented] (FLINK-41371) Row-semantic PTFs force retract mode on upsert inputs
Gustavo de Morais (Jira) via issues
-
[PR] [FLINK-34099][tests] Harden and disable CheckpointIntervalDuringBacklogITCase [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41350) A materialized table left SUSPENDED by a failed table conversion cannot be resumed
Timo Theusner (Jira) via issues
-
[PR] [FLINK-39146] Update log4j to 2.25.3 [flink]
1996fanrui (via GitHub) via issues
-
[PR] [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests [flink]
1996fanrui (via GitHub) via issues
-
Re: [PR] [FLINK-41077][rpc] Rethrow scheduled task failures in the main thread [flink]
XComp (via GitHub) via issues
-
Re: [PR] [FLINK-39748][postgres] Fix snapshot timestamp drift for historical TIMESTAMP/DATE columns [flink-cdc]
loserwang1024 (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-41315) Add the page structure for built-in function docs
Ramin Gharib (Jira) via issues
-
[jira] [Closed] (FLINK-41064) 'State TTL Heap backend end-to-end test' fails on a "Trying to access closed classloader" log4j error in the TaskManager .out files
Rui Fan (Jira) via issues
-
[jira] [Resolved] (FLINK-40577) Support ChangelogModes in ProcessTableFunctionTestHarness
Fabian Hueske (Jira) via issues
-
[PR] [BP-2.4][FLINK-40807][table] Refine the XML Schema handling of PARSE_XML [flink]
manner (via GitHub) via issues
-
Re: [PR] [FLINK-40706] Restrict jarURI hosts to globally reachable addresses and add trusted-host allowlist [flink-kubernetes-operator]
Copilot (via GitHub) via issues
-
[jira] [Updated] (FLINK-41433) Add pages for the regular expression, cast, conditional, window and utility functions
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41433][docs] Add pages for the regular expression, cast, conditional, window and utility functions [flink]
raminqaf (via GitHub) via issues
-
[jira] [Updated] (FLINK-41434) Fluss CDC source rebuilds the column mapping for every record with an older schema
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41434][pipeline-connector/fluss] Reuse column mappings when reading older Fluss schemas [flink-cdc]
fxbing (via GitHub) via issues