Messages by Thread
-
-
[PR] [BP-2.4][FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range [flink]
raminqaf (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41337) Add IS_VARIANT_NULL, VARIANT_TYPE, VARIANT_KEYS and VARIANT_EXISTS
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41340) Add VARIANT_DELETE and VARIANT_PICK
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-41366) Support disabling automatic column addition in the Fluss pipeline sink
ASF GitHub Bot (Jira) via issues
-
[jira] [Resolved] (FLINK-37381) Typo in Join document
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None
Dian Fu (Jira) via issues
-
[jira] [Commented] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-41199) PyFlink result collection fails for NULL values inside nested rows and collections
Dian Fu (Jira) via issues
-
[PR] [BP-3.7][docs][examples] Add MySQL to Fluss ingestion example (#4612) [flink-cdc]
leonardBang (via GitHub) via issues
-
[jira] [Created] (FLINK-41362) Reject VARIANT in primary key columns
Ramin Gharib (Jira) via issues
-
[jira] [Created] (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
Yaoxuan Wu (Jira) via issues
-
[PR] [runtime] Complete input admission limit enforcement [flink-agents]
wenjin272 (via GitHub) via issues
-
[PR] [BP-2.2][FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink]
spuru9 (via GitHub) via issues
-
[PR] [BP-4.0][FLINK-41376][Connectors/Elasticsearch] Upgrade Testcontainers to 1.21.4 [flink-connector-elasticsearch]
spuru9 (via GitHub) via issues
-
[jira] [Created] (FLINK-41322) JSON_QUOTE does not round-trip a character outside the BMP through JSON_UNQUOTE
sepuri sai krishna (Jira) via issues
-
[jira] [Assigned] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique
Sergey Nuyanzin (Jira) via issues
-
[PR] [BP-2.4][FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code
Purushottam Sinha (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format
Yuepeng Pan (Jira) via issues
-
[jira] [Created] (FLINK-41329) Restore tests are absent for all seven Python stream ExecNodes, four of them stateful
sepuri sai krishna (Jira) via issues
-
[jira] [Assigned] (FLINK-41341) Add VARIANT_ARRAY_APPEND and TRY_VARIANT_ARRAY_APPEND
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41364) Web dashboard: Poll checkpoint stats in the Checkpoints page and flag new data on Refresh
Purushottam Sinha (Jira) via issues
-
[jira] [Commented] (FLINK-41363) Make ALTER TABLE ADD statements idempotent
Muhammad (Jira) via issues
-
[jira] [Updated] (FLINK-41356) Support early fire in the async state interval join
ASF GitHub Bot (Jira) via issues
-
[jira] [Updated] (FLINK-41127) [release-2.4] Review and update documentation
Yuepeng Pan (Jira) via issues
-
[jira] [Assigned] (FLINK-23804) Restructure documentation of built-in functions
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-41263) Add CompiledPlan annotations to BatchExecAdaptiveJoin
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41308) Web dashboard: TaskManager Metrics "Netty Shuffle Buffers" Available/Total are always blank
ASF GitHub Bot (Jira) via issues
-
[jira] [Updated] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom
Purushottam Sinha (Jira) via issues
-
[jira] [Created] (FLINK-41347) Add VARIANT_MERGE
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently
sepuri sai krishna (Jira) via issues
-
[jira] [Commented] (FLINK-23804) Restructure documentation of built-in functions
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter
Sergey Nuyanzin (Jira) via issues
-
[PR] [hotfix][ci] Rebalance end-to-end tests in run-nightly-tests.sh [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-41367][connector-jdbc] Test the SQL Server dialect on SQL Server 2025 and cover XA [flink-connector-jdbc]
spuru9 (via GitHub) via issues
-
Re: [I] [Bug] Java `RemoteExecutionEnvironment` fails when only legacy `flink-conf.yaml` exists. [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Commented] (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
-
[PR] [FLINK-41355][table] Introduce async state version of StreamExecIntervalJoin [flink]
minxhe (via GitHub) via issues
-
[PR] Fix typo 'compatiblity' to 'compatibility' in 2024-06-18-release-cdc-3.1.1.md [flink-web]
siddiqueirshad (via GitHub) via issues
-
[jira] [Created] (FLINK-41381) Use indexed seq for generation the digest of a Calc
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41381) Use indexed seq for generation the digest of a Calc
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41381][table] Use indexed seq for generation the digest of a Calc [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Updated] (FLINK-41370) VARIANT array access in SQL returns NULL for a literal index below 1 instead of failing
ASF GitHub Bot (Jira) via issues
-
[jira] [Created] (FLINK-41339) Add VARIANT_SET, VARIANT_INSERT and their TRY_ forms
Ramin Gharib (Jira) via issues
-
[PR] [hotfix] Clean up the already-upgraded check and deploy guard [flink-kubernetes-operator]
Dennis-Mircea (via GitHub) via issues
-
[PR] [FLINK-41380][table] Make generated code for `CASE` ... `WHEN` flat [flink]
snuyanzin (via GitHub) via issues
-
[PR] [hotfix] Fix log levels and messages in the reconciler layer [flink-kubernetes-operator]
Dennis-Mircea (via GitHub) via issues
-
[jira] [Created] (FLINK-41380) Make generated code in case of CASE ... WHEN friendlier to code splitter
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-41380) Make generated code in case of CASE ... WHEN friendlier to code splitter
Sergey Nuyanzin (Jira) via issues
-
[PR] [hotfix][test] Use `-Dfast` for `test_kubernetes_itcases.sh` [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use
Dian Fu (Jira) via issues
-
[jira] [Resolved] (FLINK-41263) Add CompiledPlan annotations to BatchExecAdaptiveJoin
Sergey Nuyanzin (Jira) via issues
-
[jira] [Assigned] (FLINK-41267) Cluster info fails for jobs without checkpointing, logging a WARN on every reconcile
Gyula Fora (Jira) via issues
-
[jira] [Updated] (FLINK-41330) VARIANT array access with a BIGINT index wraps around and returns the wrong element
ASF GitHub Bot (Jira) via issues
-
[jira] [Created] (FLINK-41366) Support disabling automatic column addition in the Fluss pipeline sink
Xiaobing Fang (Jira) via issues
-
[PR] [FLINK-30975][filesystems] Update the S3 filesystems to Hadoop 3.4.3 and AWS SDK v2 [flink]
MartijnVisser (via GitHub) via issues
-
[PR] [FLINK-40788][e2e] Raise TaskManager metaspace in the heavy deployment test [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Updated] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11
ASF GitHub Bot (Jira) via issues
-
[jira] [Created] (FLINK-41379) Flink on YARN doesn't report missing Kerberos credentials with Hadoop 3
Martijn Visser (Jira) via issues
-
[jira] [Updated] (FLINK-41379) Flink on YARN doesn't report missing Kerberos credentials with Hadoop 3
Martijn Visser (Jira) via issues
-
[PR] [BP-1.20][hotfix][docs] Fix temporal table function examples [flink]
MartijnVisser (via GitHub) via issues
-
[PR] [FLINK-36694][filesystems] Update Azure, OSS and GCS to Hadoop 3.4.3 [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Assigned] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules
Martijn Visser (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered
Rui Fan (Jira) via issues
-
[jira] [Created] (FLINK-41336) FLIP-618: Edit, Inspect and Build VARIANT Values
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-36694) Update Hadoop to 3.4.3 for the Azure, OSS and GCS filesystems
Martijn Visser (Jira) via issues
-
[PR] [python][plan] Split chat model action into per-model attempts [flink-agents]
sangkyoonnam (via GitHub) via issues
-
[PR] [BP-2.2][FLINK-39146] Update log4j to 2.25.3 [flink]
spuru9 (via GitHub) via issues
-
[PR] [FLINK-37247][filesystems] Implement common Hadoop file system integration tests for GCS [flink]
MartijnVisser (via GitHub) via issues
-
[PR] [BP-2.4][hotfix][docs] Fix temporal table function examples [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Assigned] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11
Martijn Visser (Jira) via issues
-
[jira] [Commented] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11
Martijn Visser (Jira) via issues
-
[jira] [Created] (FLINK-41378) Raise the minimum supported Hadoop version to 3.4.3
Martijn Visser (Jira) via issues
-
[jira] [Updated] (FLINK-41378) Raise the minimum supported Hadoop version to 3.4.3
Martijn Visser (Jira) via issues
-
Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Assigned] (FLINK-36694) Update Hadoop shaded from 3.3.4 to 3.4.1
Martijn Visser (Jira) via issues
-
[jira] [Updated] (FLINK-36694) Update Hadoop to 3.4.3 for the Azure, OSS and GCS filesystems
Martijn Visser (Jira) via issues
-
[jira] [Updated] (FLINK-41254) Two-phase window aggregation loses buffered records when a source subtask becomes idle
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-41254][table-runtime] Flush local window aggregates before for… [flink]
onceicy (via GitHub) via issues
-
[PR] [BP-2.3][hotfix][docs] Fix temporal table function examples [flink]
MartijnVisser (via GitHub) via issues
-
[jira] [Updated] (FLINK-41216) Retracting ROW_NUMBER Top-N emits +U before -U for rows moving up, so operators keyed by the input upsert key lose rows
Gustavo de Morais (Jira) via issues
-
[jira] [Commented] (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
Yahya Kisana (Jira) via issues
-
[PR] [integration][java] Send user images, documents, video and audio to Amazon Bedrock [flink-agents]
Zhuoxi2000 (via GitHub) via issues
-
Re: [PR] [FLINK-40139][Connectors/Kafka] test: Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka]
slachiewicz (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Yuepeng Pan (Jira) via issues
-
Re: [PR] [FLINK-40615][Connectors/Kafka] fix: Prevent duplicate partition assignment in KafkaSourceEnumerator [flink-connector-kafka]
slachiewicz (via GitHub) via issues
-
[jira] [Updated] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps
Dian Fu (Jira) via issues
-
[jira] [Assigned] (FLINK-40976) JoinToMultiJoinForReorderRule applies a post-join filter twice when merging joins for reorder
Hao Li (Jira) via issues
-
[jira] [Updated] (FLINK-23758) PyFlink __invert__ has wrong semantics
Dian Fu (Jira) via issues
-
[jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown
Purushottam Sinha (Jira) via issues
-
[jira] [Updated] (FLINK-41321) ARRAY[m1] = ARRAY[m2] is FALSE although m1 = m2 is TRUE for the same two maps
sepuri sai krishna (Jira) via issues
-
[jira] [Created] (FLINK-41330) VARIANT array access with a BIGINT index wraps around and returns the wrong element
Ramin Gharib (Jira) via issues
-
[PR] [hotfix][ci] Remove obsolete libssl download for e2e netty-tcnative on Ubuntu 26.04 [flink]
snuyanzin (via GitHub) via issues
-
[PR] [BP-2.2][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Commented] (FLINK-41319) REGEXP_INSTR disagrees with POSITION, LOCATE and INSTR for characters outside the BMP
sepuri sai krishna (Jira) via issues
-
[jira] [Updated] (FLINK-23804) Restructure documentation of built-in functions
Ramin Gharib (Jira) via issues
-
[jira] [Comment Edited] (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
Purushottam Sinha (Jira) via issues
-
[jira] [Updated] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty
Dian Fu (Jira) via issues
-
[PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec.java [flink]
siddiqueirshad (via GitHub) via issues
-
[PR] [FLINK-41365][Connectors/DynamoDB] Make non-blocking GetRecords calls in the DynamoDB Streams split reader [flink-connector-aws]
gguptp (via GitHub) via issues
-
[jira] [Commented] (FLINK-41352) [mongodb] Support change events larger than 16MB with $changeStreamSplitLargeEvent
Sonal Maheshwari (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41320) CAST of ARRAY, ROW or MAP to CHAR/VARCHAR(n) returns fewer than n characters and can insert a '?'
sepuri sai krishna (Jira) via issues
-
[jira] [Commented] (FLINK-41320) CAST of ARRAY, ROW or MAP to CHAR/VARCHAR(n) returns fewer than n characters and can insert a '?'
sepuri sai krishna (Jira) via issues
-
[jira] [Resolved] (FLINK-39386) For Flink 2.x+, support limit the rate at the source
Yanquan Lv (Jira) via issues
-
[jira] [Commented] (FLINK-41014) Add an adaptive retry mode to the native S3 connector
Samrat Deb (Jira) via issues
-
[jira] [Closed] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-41311] Unresponsive JobManager is never reported [flink-kubernetes-operator]
Dennis-Mircea (via GitHub) via issues
-
[PR] [api][plan][python] Support rule-based and custom model routing [flink-agents]
sangkyoonnam (via GitHub) via issues
-
[PR] [FLINK-39624][state] Return null from TtlListState#asyncGet for empty state [flink]
spuru9 (via GitHub) via issues
-
[PR] [runtime][java] Checkpoint in-flight actions without draining workers [flink-agents]
wenjin272 (via GitHub) via issues
-
[PR] [docs][examples] Add MySQL to Fluss ingestion example [flink-cdc]
leonardBang (via GitHub) via issues