Messages by Thread
-
-
[jira] [Updated] (FLINK-41214) Declare a materialized table with Table#materializeInto
ASF GitHub Bot (Jira) via issues
-
[jira] [Assigned] (FLINK-41307) PyFlink TableResult.collect() changes TIMESTAMP values in a DST gap or before 1902 (converted through the JVM and Python local time zones)
Dian Fu (Jira) via issues
-
[jira] [Resolved] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction
Martijn Visser (Jira) via issues
-
[jira] [Resolved] (FLINK-41381) Use indexed seq for generation the digest of a Calc
Sergey Nuyanzin (Jira) via issues
-
[jira] [Created] (FLINK-41398) Suspend, resume and drop a materialized table through its handle
Timo Theusner (Jira) via issues
-
[jira] [Updated] (FLINK-41315) Add the page structure for built-in function docs
ASF GitHub Bot (Jira) via issues
-
[jira] [Created] (FLINK-41397) Alter a materialized table's query and options with alter()
Timo Theusner (Jira) via issues
-
[jira] [Created] (FLINK-41394) Read and derive from a materialized table handle
Timo Theusner (Jira) via issues
-
[jira] [Created] (FLINK-41410) Push nested field accesses below joins to reduce join shuffle and state size
Fabian Hueske (Jira) via issues
-
[PR] [hotfix][docs] Bump Hugo to v0.126.3 [flink]
raminqaf (via GitHub) via issues
-
[PR] [runtime][java][python] Discover MCP tools and prompts at operator startup [flink-agents]
sangkyoonnam (via GitHub) via issues
-
[jira] [Created] (FLINK-41404) Blue/Green: after an aborted transition the retry restores the aborted attempt's state instead of the serving deployment's fresh savepoint
Noa Ramon (Jira) via issues
-
[I] [Bug][runtime][java] Internal subagents cannot inherit model routers [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink]
lincoln-lil (via GitHub) via issues
-
[jira] [Assigned] (FLINK-39804) Nested projection fields not pushed down to source
Fabian Hueske (Jira) via issues
-
[jira] [Updated] (FLINK-41408) Watermark on a computed column inherited through CREATE TABLE LIKE fails validation
Martijn Visser (Jira) via issues
-
[PR] [hotfix][runtime] Initialize output identity in routing recovery tests [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Created] (FLINK-41409) A view that selects CURRENT_DATE or LOCALTIME without an alias cannot be queried
Martijn Visser (Jira) via issues
-
[jira] [Commented] (FLINK-41381) Use indexed seq for generation the digest of a Calc
Sergey Nuyanzin (Jira) via issues
-
[jira] [Created] (FLINK-41408) Watermark on a computed column inherited through CREATE TABLE LIKE fails validation
Martijn Visser (Jira) via issues
-
[jira] [Resolved] (FLINK-41383) REGEXP, REGEXP_EXTRACT and REGEXP_REPLACE look up a constant pattern for every row
Sergey Nuyanzin (Jira) via issues
-
Re: [I] [Bug] Bounded workflows silently drop records in batch mode with multiple keys [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Updated] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness
Martijn Visser (Jira) via issues
-
[jira] [Created] (FLINK-41402) Change a materialized table's distribution with alter()
Timo Theusner (Jira) via issues
-
[jira] [Commented] (FLINK-41383) REGEXP, REGEXP_EXTRACT and REGEXP_REPLACE look up a constant pattern for every row
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41407) Fix code examples in the documentation that don't work on master
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41407][docs] Fix code examples in the documentation [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Updated] (FLINK-41406) VARIANT mixed with another type in UNION ALL, CASE or VALUES is cast implicitly
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41406][table] Reject mixing VARIANT with other types in UNION ALL, CASE and VALUES [flink]
raminqaf (via GitHub) via issues
-
[jira] [Created] (FLINK-41406) VARIANT mixed with another type in UNION ALL, CASE or VALUES is cast implicitly
Ramin Gharib (Jira) via issues
-
[PR] [api][integrations][java][python] Support DashScope multimodal models [flink-agents]
joeyutong (via GitHub) via issues
-
Re: [PR] [FLINK-40807][table] Add XML_STRING function [flink]
manner (via GitHub) via issues
-
[PR] Bump org.jsoup:jsoup from 1.15.3 to 1.23.2 in /flink-kubernetes-docs [flink-kubernetes-operator]
dependabot[bot] (via GitHub) via issues
-
[jira] [Closed] (FLINK-41375) JobManager crash loops are detected only in the back-off phase and reported without the termination reason
Gyula Fora (Jira) via issues
-
[jira] [Updated] (FLINK-41326) chore: update JOSDK to v5.6.3
ASF GitHub Bot (Jira) via issues
-
[jira] [Created] (FLINK-41391) YarnFileStageTestS3ITCase never runs
Martijn Visser (Jira) via issues
-
[jira] [Created] (FLINK-41405) Comparing a VARIANT expression with itself bypasses the no-equality check
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-41403) Blue/Green child FlinkDeployments do not inherit the parent's labels, so a label-selector-scoped operator never reconciles them
ASF GitHub Bot (Jira) via issues
-
[jira] [Commented] (FLINK-41292) PyFlink batch: pandas UDAF in an aggregation without GROUP BY returns no row for an empty input
Sangkyoon Nam (Jira) via issues
-
[PR] [FLINK-41378][build] Raise the minimum Hadoop version to 3.4.3 [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Updated] (FLINK-41404) Blue/Green: after an aborted transition the retry restores the aborted attempt's state instead of the serving deployment's fresh savepoint
Noa Ramon (Jira) via issues
-
[jira] [Created] (FLINK-41403) Blue/Green child FlinkDeployments do not inherit the parent's labels, so a label-selector-scoped operator never reconciles them
Noa Ramon (Jira) via issues
-
[jira] [Created] (FLINK-41400) Refresh a materialized table from the Table API
Timo Theusner (Jira) via issues
-
[jira] [Created] (FLINK-41399) Convert an existing table into a materialized table with materializeInto
Timo Theusner (Jira) via issues
-
[jira] [Created] (FLINK-41393) Remove the Hadoop 2 compatibility code
Martijn Visser (Jira) via issues
-
[jira] [Created] (FLINK-41392) Run the YARN Kerberos e2e tests again
Martijn Visser (Jira) via issues
-
[jira] [Updated] (FLINK-41389) flink-rpc-akka bundles a second copy of the shaded Netty
Martijn Visser (Jira) via issues
-
[PR] [FLINK-41389][rpc] Do not bundle Netty in flink-rpc-akka [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Closed] (FLINK-41267) Cluster info fails for jobs without checkpointing, logging a WARN on every reconcile
Gyula Fora (Jira) via issues
-
Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator]
gyfora (via GitHub) via issues
-
[jira] [Commented] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL
Moritz Manner (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction
Martijn Visser (Jira) via issues
-
[I] [Bug][runtime] Chat child Actions persist unfinished parent memory before replay [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] [docs] Add Kubernetes deployment guide [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] [runtime][java] Complete batch workflows before key switches [flink-agents]
wellkilo (via GitHub) via issues
-
[jira] [Updated] (FLINK-41388) flink-s3-fs-native doesn't list the third-party code bundled in Netty
Martijn Visser (Jira) via issues
-
[jira] [Updated] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules
Martijn Visser (Jira) via issues
-
[jira] [Created] (FLINK-41388) flink-s3-fs-native doesn't list the third-party code bundled in Netty
Martijn Visser (Jira) via issues
-
Re: [PR] [DISCUSS][FLIP-597][FLIP-598][FLIP-601][filesystem] Add common object storage stream abstractions [flink]
github-actions[bot] (via GitHub) via issues
-
Re: [PR] [FLINK-39310][web-ui] Use programArgsList in JSON body instead of program-args query parameter [flink]
github-actions[bot] (via GitHub) via issues
-
[jira] [Updated] (FLINK-41387) Reduce unnecessary ADD COLUMN requests in the Fluss pipeline sink
ASF GitHub Bot (Jira) via issues
-
[jira] [Commented] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3
Prashant Sharma (Jira) via issues
-
[PR] [runtime][java] Fix model router inheritance in internal subagents [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Created] (FLINK-41387) Reduce unnecessary ADD COLUMN requests in the Fluss pipeline sink
Xiaobing Fang (Jira) via issues
-
[PR] [FLINK-41387][pipeline-connector/fluss] Add only missing columns to Fluss tables [flink-cdc]
fxbing (via GitHub) via issues
-
[jira] [Created] (FLINK-41386) Decorrelation fails when a correlated scalar subquery projects a field of a ROW expression
dylanhz (Jira) via issues
-
[jira] [Assigned] (FLINK-41264) FileSinkAvroWritersTests.test_avro_basic_write fails with AssertionError: False != True
Dian Fu (Jira) via issues
-
[PR] [hotfix][ci] Use released Flink versions in v4.0 CI [flink-connector-elasticsearch]
wenjin272 (via GitHub) via issues
-
[PR] [hotfix][ci] Use released Flink versions in v3.1 CI [flink-connector-elasticsearch]
wenjin272 (via GitHub) via issues
-
[PR] [FLINK-41327][table-runtime] Compare binary IN point-set values by content [flink]
Zerolzj (via GitHub) via issues
-
[jira] [Created] (FLINK-41385) Documentation: flink-sql-connector-hive-3.1.3_2.12-2.3.0.jar link in Flink 2.x docs points to non-existent artifact
Yao Zhang (Jira) via issues
-
[jira] [Updated] (FLINK-41384) Extra parse methods for JSON and XML functions in CASE branches
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
snuyanzin (via GitHub) via issues
-
Re: [PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
flinkbot (via GitHub) via issues
-
Re: [PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
snuyanzin (via GitHub) via issues
-
Re: [PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
twalthr (via GitHub) via issues
-
Re: [PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
snuyanzin (via GitHub) via issues
-
Re: [PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
twalthr (via GitHub) via issues
-
Re: [PR] [FLINK-41384][table] Extra parse methods for JSON and XML functions in `CASE`, `OR`, `COALESCE` branches [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41384) Extra parse methods for JSON and XML functions in CASE branches
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41383) REGEXP, REGEXP_EXTRACT and REGEXP_REPLACE look up a constant pattern for every row
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41383][table] `REGEXP`, `REGEXP_EXTRACT` and `REGEXP_REPLACE` look up a constant pattern for every row [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41383) REGEXP, REGEXP_EXTRACT and REGEXP_REPLACE look up a constant pattern for every row
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41382) Split generated methods can still be too large to be JIT-compiled
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41382][table] Ensure list of split calls is also splitted if required [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41348) Merge nested VARIANT modification calls into one pass
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink]
1996fanrui (via GitHub) via issues
-
[PR] [BP-2.4][FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink]
raminqaf (via GitHub) via issues
-
[jira] [Created] (FLINK-41382) Split generated methods can still be too large to be JIT-compiled
Sergey Nuyanzin (Jira) via issues
-
[PR] [api][java][python] Support a stable UID for the agent operator [flink-agents]
sangkyoonnam (via GitHub) via issues
-
[PR] [FLINK-40319][FLINK-41301][table] Allow CAST from a VARIANT string to BINARY and throw TableRuntimeException for every failed VARIANT cast [flink]
raminqaf (via GitHub) via issues