Messages by Thread
-
-
[jira] [Created] (FLINK-41344) Add VARIANT_CONTAINS with a shared value-equality rule
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41346) Add VARIANT_OBJECT_AGG
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns
Rui Fan (Jira) via issues
-
[jira] [Assigned] (FLINK-41335) Release Testing: Verify FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Mika Naylor (Jira) via issues
-
[jira] [Updated] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41345) Add VARIANT_OBJECT, VARIANT_ARRAY, VARIANT_NULL and TO_VARIANT
Ramin Gharib (Jira) via issues
-
Re: [PR] [FLINK-40304][table] Fix PTF partition columns for multiple table arguments [flink]
github-actions[bot] (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41308) Web dashboard: TaskManager Metrics "Netty Shuffle Buffers" Available/Total are always blank
Robert Metzger (Jira) via issues
-
[jira] [Created] (FLINK-41356) Support early fire in the async state interval join
Aaron He (Jira) via issues
-
[jira] [Updated] (FLINK-40319) Add a raw-bytes accessor for VARIANT string values, and use it to validate UTF-8 on the character-string cast and to let a string variant reach a binary target
ASF GitHub Bot (Jira) via issues
-
[jira] [Updated] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion
Yuepeng Pan (Jira) via issues
-
[jira] [Assigned] (FLINK-41308) Web dashboard: TaskManager Metrics "Netty Shuffle Buffers" Available/Total are always blank
Robert Metzger (Jira) via issues
-
[PR] [hotfix][docs] Apply review guidance during development [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Created] (FLINK-41355) Introduce async state version of StreamExecIntervalJoin
Aaron He (Jira) via issues
-
[jira] [Updated] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41301) Throw TableRuntimeException for every failed cast from VARIANT
Ramin Gharib (Jira) via issues
-
[jira] [Closed] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join
Fabian Hueske (Jira) via issues
-
[jira] [Created] (FLINK-41354) Dispatcher never terminates when it is stopped while a cleanup retry is pending, so the next leader never starts
Mohsen Rezaei (Jira) via issues
-
[PR] [docs][paimon] Add MySQL CDC Action migration guide [flink-cdc]
lvyanquan (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41317) [pipeline-connector/kafka] NullPointerException when serializing REPLACE events in canal-json and debezium-json
Yanquan Lv (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
Samrat Deb (Jira) via issues
-
[jira] [Updated] (FLINK-41311) Unresponsive JobManager is never reported
Dennis-Mircea Ciupitu (Jira) via issues
-
[jira] [Closed] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom
Ferenc Csaky (Jira) via issues
-
[jira] [Commented] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique
Sergey Nuyanzin (Jira) via issues
-
[jira] [Commented] (FLINK-41301) Throw TableRuntimeException for every failed cast from VARIANT
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-40319) Allow CAST from a VARIANT string value to BINARY and VARBINARY
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-40319) Allow CAST from a VARIANT string value to BINARY and VARBINARY
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41286) Release Testing: Verify FLIP-585: Introduce Lazy Loading for HistoryServer
Mika Naylor (Jira) via issues
-
[jira] [Created] (FLINK-41370) VARIANT array access in SQL returns NULL for a literal index below 1 instead of failing
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41369) Flink CDC: Run the Postgres, SQL Server and Db2 tests on maintained database images
Purushottam Sinha (Jira) via issues
-
[jira] [Assigned] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join
Mika Naylor (Jira) via issues
-
[jira] [Closed] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view
Ferenc Csaky (Jira) via issues
-
[jira] [Updated] (FLINK-41363) Make ALTER TABLE ADD statements idempotent
Muhammad (Jira) via issues
-
[jira] [Resolved] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join
Fabian Hueske (Jira) via issues
-
[jira] [Created] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join
Fabian Hueske (Jira) via issues
-
[jira] [Updated] (FLINK-41367) JDBC: Test SQL Server dialect on SQL Server 2025, not retired Azure SQL Edge; cover XA
ASF GitHub Bot (Jira) via issues
-
[jira] [Resolved] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41367) JDBC: Test SQL Server dialect on SQL Server 2025, not retired Azure SQL Edge; cover XA
Purushottam Sinha (Jira) via issues
-
[jira] [Commented] (FLINK-41293) PyFlink batch: pandas UDAF over ROWS BETWEEN n PRECEDING AND k PRECEDING (k >= 2) aggregates rows outside the frame for the first rows of a partition
Yahya Kisana (Jira) via issues
-
[PR] [hotfix][ci] Cancel superseded CI runs for the same PR [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41357) FLIP-608: Flink on Ray — Ray Resource Backend For Flink
Dian Fu (Jira) via issues
-
Re: [PR] [FLINK-41108][python] Use the TTL config when invalidating cached state after namespace merges [flink]
dianfu (via GitHub) via issues
-
[PR] [FLINK-41366][pipeline-connector/fluss] Support disabling automatic column addition [flink-cdc]
fxbing (via GitHub) via issues
-
Re: [PR] [FLINK-41103][python] Clear ValueState without adding None in update(None) [flink]
dianfu (via GitHub) via issues
-
Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink]
github-actions[bot] (via GitHub) via issues
-
Re: [PR] [FLINK-34376][table] Fix DECIMAL precision loss in multiplication type inference [flink]
github-actions[bot] (via GitHub) via issues
-
Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink]
github-actions[bot] (via GitHub) via issues
-
Re: [PR] [FLINK-40609][python] Infer ROW types from dataclass, NamedTuple and tuple type hints [flink]
dianfu (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41330) VARIANT array access with a BIGINT index wraps around and returns the wrong element
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-39847) FLIP-578: Support in-place conversion of a table to a materialized table
Yuepeng Pan (Jira) via issues
-
Re: [PR] [FLINK-40966][pipeline-connector/fluss] Reuse metadata clients across schema operations [flink-cdc]
loserwang1024 (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-41325) COMPILE PLAN emits no state array for a temporal join or MATCH_RECOGNIZE, so their TTL cannot be configured as documented
sepuri sai krishna (Jira) via issues
-
[jira] [Commented] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-40628) PyFlink TTL initialization can hang task threads and leave jobs stuck in INITIALIZING
Dian Fu (Jira) via issues
-
[jira] [Commented] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
Samrat Deb (Jira) via issues
-
Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka]
sqd (via GitHub) via issues
-
[PR] [BP-2.4][FLINK-41362][table] Reject VARIANT in primary key columns [flink]
raminqaf (via GitHub) via issues
-
[jira] [Closed] (FLINK-41362) Reject VARIANT in primary key columns
Ramin Gharib (Jira) via issues
-
[jira] [Resolved] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter
Sergey Nuyanzin (Jira) via issues
-
[jira] [Created] (FLINK-41365) Remove queue based polling from DDB Connector
Abhi Gupta (Jira) via issues
-
[jira] [Commented] (FLINK-41328) GROUP BY, DISTINCT, UNION and a join on a MAP column split one value into several in streaming mode
sepuri sai krishna (Jira) via issues
-
[PR] [BP-2.4][FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down [flink]
jnh5y (via GitHub) via issues
-
[jira] [Updated] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed
Dian Fu (Jira) via issues
-
Re: [PR] [hotfix][ci] Build flink-shaded for e2e only once [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41285) Release Testing: Verify FLIP-584: Support Pluggable Storage Backend for HistoryServer
Yuepeng Pan (Jira) via issues
-
Re: [PR] [FLINK-37502][docs] Translate documentation for Disaggregated State Management into Chinese [flink]
arvindKandpal-ksolves (via GitHub) via issues
-
[jira] [Created] (FLINK-41332) COMPILE PLAN fails for a query with a UUID literal
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (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) via issues
-
[PR] [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink]
raminqaf (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes
Yuepeng Pan (Jira) via issues
-
[jira] [Created] (FLINK-41358) Streaming OVER window ordered by a non-time column (RANGE frame) drops all equal rows from the aggregate when one of them is retracted
Yaoxuan Wu (Jira) via issues
-
Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink]
gustavodemorais (via GitHub) via issues
-
[jira] [Closed] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion
Yuepeng Pan (Jira) via issues
-
[PR] [api][java][python] Propagate user context from request events to responses [flink-agents]
HsbcJone (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41345) Add VARIANT_OBJECT, VARIANT_ARRAY, VARIANT_NULL and TO_VARIANT
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22
Nic Townsend (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22
Nic Townsend (Jira) via issues
-
[PR] [hotfix][docs] Fix typos in Hive dialect docs [flink]
arvindKandpal-ksolves (via GitHub) via issues
-
[jira] [Assigned] (FLINK-37381) Typo in Join document
Sergey Nuyanzin (Jira) via issues
-
[PR] [FLINK-41362][table] Reject VARIANT in primary key columns [flink]
raminqaf (via GitHub) via issues
-
[jira] [Closed] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout
Gyula Fora (Jira) via issues
-
[jira] [Created] (FLINK-41363) Make ALTER TABLE ADD statements idempotent
Muhammad (Jira) via issues
-
[jira] [Assigned] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-38647][connect/postgres] Support changelog-mode=upsert emitting REPLACE events [flink-cdc]
dev-donghwan (via GitHub) via issues
-
[PR] [FLINK-41361][core] Bound VARIANT object and array sizes by the value… [flink]
raminqaf (via GitHub) via issues
-
[jira] [Updated] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating
ASF GitHub Bot (Jira) via issues
-
[PR] [BP-2.4][FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink]
raminqaf (via GitHub) via issues