dev  

Messages by Thread

• [jira] [Created] (FLINK-41425) Drop Azure cron build from nightly Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41424) ForSt: support dropping keyed state for removed state descriptors Francis (Jira) via dev
• [jira] [Created] (FLINK-41423) SinkUpsertMaterializer compares upsert keys with SQL equality instead of bytes and drops rows Gustavo de Morais (Jira) via dev
• [jira] [Created] (FLINK-41419) FLIP-622: Add built-in DEDUPLICATE, DEDUPLICATE_WINDOW PTF Vas Shabu (Jira) via dev
• [jira] [Created] (FLINK-41420) "Job failed during initialization of JobManager" alert can no longer appear Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41418) TaskManager page keeps showing "no longer registered" after switching to another TaskManager Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41422) Remove the built-in DEDUPLICATE_KEEP_FIRST process table function Vas Shabu (Jira) via dev
• [jira] [Created] (FLINK-41415) CommonTestUtils.getLatestCompletedCheckpointPath can return a subsumed checkpoint Martijn Visser (Jira) via dev
• [DISCUSS] FLIP-622: Add built-in DEDUPLICATE and DEDUPLICATE_WINDOW PTFs Vas Shabu
  • Re: [DISCUSS] FLIP-622: Add built-in DEDUPLICATE and DEDUPLICATE_WINDOW PTFs Gustavo de Morais
• [jira] [Created] (FLINK-41421) StateCatalog database names can resolve outside the configured snapshot directories Luca Castelli (Jira) via dev
• [jira] [Created] (FLINK-41416) StateFutureUtils#toIterable throws ClassCastException for list and map state with TTL Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41417) TtlMapState async iterators always report isEmpty() as false Martijn Visser (Jira) via dev
• [2.4] Release sync meeting summary – 6 November 2026 Sumin Joo
• [jira] [Created] (FLINK-41414) Add AGENTS.md guidance for adding a built-in function Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41413) Connectors / MongoDB: Bump mongodb8.version to 8.0.37+ so CI works on ubuntu-26.04 Purushottam Sinha (Jira) via dev
• [jira] [Created] (FLINK-41396) Inspect a materialized table's continuous refresh job Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41395) Explain materialized table declarations and refresh pipelines Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41412) Support IF EXISTS for ALTER VIEW, DATABASE, CATALOG and MATERIALIZED TABLE sepuri sai krishna (Jira) via dev
• [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 dev
• [jira] [Created] (FLINK-41400) Refresh a materialized table from the Table API Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41411) GROUP BY, DISTINCT and COUNT(DISTINCT) on a BITMAP column are rejected in batch but work in streaming sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41394) Read and derive from a materialized table handle Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41397) Alter a materialized table's query and options with alter() Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41405) Comparing a VARIANT expression with itself bypasses the no-equality check Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41410) Push nested field accesses below joins to reduce join shuffle and state size Fabian Hueske (Jira) via dev
• [jira] [Created] (FLINK-41409) A view that selects CURRENT_DATE or LOCALTIME without an alias cannot be queried Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41408) Watermark on a computed column inherited through CREATE TABLE LIKE fails validation Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41388) flink-s3-fs-native doesn't list the third-party code bundled in Netty Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41398) Suspend, resume and drop a materialized table through its handle Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41390) Clean up after materialized table refresh-job failures in CREATE and SUSPEND Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41402) Change a materialized table's distribution with alter() Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41406) VARIANT mixed with another type in UNION ALL, CASE or VALUES is cast implicitly Ramin Gharib (Jira) via dev
• [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 dev
• [jira] [Created] (FLINK-41407) Fix code examples in the documentation that don't work on master Martijn Visser (Jira) via dev
• [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 dev
• [jira] [Created] (FLINK-41401) Evolve a materialized table's schema with alter() Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41399) Convert an existing table into a materialized table with materializeInto Timo Theusner (Jira) via dev
• [jira] [Created] (FLINK-41393) Remove the Hadoop 2 compatibility code Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41391) YarnFileStageTestS3ITCase never runs Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41392) Run the YARN Kerberos e2e tests again Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41389) flink-rpc-akka bundles a second copy of the shaded Netty Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41387) Reduce unnecessary ADD COLUMN requests in the Fluss pipeline sink Xiaobing Fang (Jira) via dev
• [jira] [Created] (FLINK-41386) Decorrelation fails when a correlated scalar subquery projects a field of a ROW expression dylanhz (Jira) via dev
• [jira] [Created] (FLINK-41384) Extra parse methods for JSON and XML functions in CASE branches Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41383) REGEXP, REGEXP_EXTRACT and REGEXP_REPLACE look up a constant pattern for every row Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41382) Split generated methods can still be too large to be JIT-compiled Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41332) COMPILE PLAN fails for a query with a UUID literal Ramin Gharib (Jira) via dev
• [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 dev
• [jira] [Created] (FLINK-41331) Move python header installation to docker image Sergey Nuyanzin (Jira) via dev
• [RESULT][VOTE] FLIP-618: Edit, Inspect and Build VARIANT Values Ramin Gharib
• [jira] [Created] (FLINK-41329) Restore tests are absent for all seven Python stream ExecNodes, four of them stateful sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating Ramin Gharib (Jira) via dev
• [jira] [Created] (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 dev
• [jira] [Created] (FLINK-41355) Introduce async state version of StreamExecIntervalJoin Aaron He (Jira) via dev
• [jira] [Created] (FLINK-41337) Add IS_VARIANT_NULL, VARIANT_TYPE, VARIANT_KEYS and VARIANT_EXISTS Ramin Gharib (Jira) via dev
• [PR] [hotfix] Reduce image size [flink-ci-docker] snuyanzin (via GitHub) via dev
  • Re: [PR] [hotfix] Reduce image size [flink-ci-docker] snuyanzin (via GitHub) via dev
  • Re: [PR] [hotfix] Reduce image size [flink-ci-docker] snuyanzin (via GitHub) via dev
  • Re: [PR] [hotfix] Reduce image size [flink-ci-docker] snuyanzin (via GitHub) via dev
• [jira] [Created] (FLINK-41362) Reject VARIANT in primary key columns Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41381) Use indexed seq for generation the digest of a Calc Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41380) Make generated code in case of CASE ... WHEN friendlier to code splitter Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41379) Flink on YARN doesn't report missing Kerberos credentials with Hadoop 3 Martijn Visser (Jira) via dev
• [jira] [Created] (FLINK-41378) Raise the minimum supported Hadoop version to 3.4.3 Martijn Visser (Jira) via dev
• [DISCUSS] FLIP-621: Add TO_APPEND built-in PTF Gustavo de Morais
  • Re: [DISCUSS] FLIP-621: Add TO_APPEND built-in PTF Timo Walther via dev
  • Re: [DISCUSS] FLIP-621: Add TO_APPEND built-in PTF Gustavo de Morais
  • Re: [DISCUSS] FLIP-621: Add TO_APPEND built-in PTF Ferenc Csaky via dev
  • Re: [DISCUSS] FLIP-621: Add TO_APPEND built-in PTF Hao Li
  • Re: [DISCUSS] FLIP-621: Add TO_APPEND built-in PTF Gustavo de Morais
• [jira] [Created] (FLINK-41303) Web UI job submission fails with long program arguments sanqingleo (Jira) via dev
• [jira] [Created] (FLINK-41375) JobManager crash loops are detected only in the back-off phase and reported without the termination reason Dennis-Mircea Ciupitu (Jira) via dev
• [jira] [Created] (FLINK-41377) Connectors/Elasticsearch: Update Flink versions in the weekly CI matrix Purushottam Sinha (Jira) via dev
• [jira] [Created] (FLINK-41376) Connectors/Elasticsearch: Upgrade Testcontainers so ITCases run on ubuntu-26.04 runners Purushottam Sinha (Jira) via dev
• [DISCUSS] FLIP-620: Structured errors for Table API and SQL Timo Walther via dev
  • Re: [DISCUSS] FLIP-620: Structured errors for Table API and SQL Krishna Sai
  • Re: [DISCUSS] FLIP-620: Structured errors for Table API and SQL Timo Walther via dev
  • Re: [DISCUSS] FLIP-620: Structured errors for Table API and SQL Krishna Sai
  • Re: [DISCUSS] FLIP-620: Structured errors for Table API and SQL Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-620: Structured errors for Table API and SQL Timo Walther via dev
• [Flink CDC 3.7.0] Potential loss of PostGIS geometry structure in PostgreSQL Pipeline Connector 2013----���� via dev
• [jira] [Created] (FLINK-41345) Add VARIANT_OBJECT, VARIANT_ARRAY, VARIANT_NULL and TO_VARIANT Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41374) Add null short curcuit for GREATEST/LEAST Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41373) Blue/Green: after an aborted transition, the next deploy restores from a stale savepoint Jing Hung (Jira) via dev
• [jira] [Created] (FLINK-41372) [Docs] Document disabling "Use '--release' option" in IntelliJ to prevent javac failure with --add-exports Younes Mahmoudi (Jira) via dev
• [jira] [Created] (FLINK-41371) Row-semantic PTFs force retract mode on upsert inputs Gustavo de Morais (Jira) via dev
• [jira] [Created] (FLINK-41340) Add VARIANT_DELETE and VARIANT_PICK Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41347) Add VARIANT_MERGE Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41368) Release Testing: Verify FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira) via dev
• [jira] [Created] (FLINK-41352) [mongodb] Support change events larger than 16MB with $changeStreamSplitLargeEvent Sonal Maheshwari (Jira) via dev
  • Re:[jira] [Created] (FLINK-41352) [mongodb] Support change events larger than 16MB with $changeStreamSplitLargeEvent z_mmG
• [jira] [Created] (FLINK-41298) PARSE_JSON, TRY_PARSE_JSON and the raw format drop content after the first JSON value Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41346) Add VARIANT_OBJECT_AGG Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41304) Support canary resources on FlinkDeployment only Dennis-Mircea Ciupitu (Jira) via dev
• [jira] [Created] (FLINK-41330) VARIANT array access with a BIGINT index wraps around and returns the wrong element Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41353) [Kafka] KafkaSource rejects auto.offset.reset=by_duration:<duration> since FLINK-39888 seongsu shin (Jira) via dev
• [jira] [Created] (FLINK-41370) VARIANT array access in SQL returns NULL for a literal index below 1 instead of failing Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41369) Flink CDC: Run the Postgres, SQL Server and Db2 tests on maintained database images Purushottam Sinha (Jira) via dev
• [Discussion] Schema Evolution inside Flink SQL M Junaid
  • Re: [Discussion] Schema Evolution inside Flink SQL Jim Pizagno
• [jira] [Created] (FLINK-41367) JDBC: Test SQL Server dialect on SQL Server 2025, not retired Azure SQL Edge; cover XA Purushottam Sinha (Jira) via dev
• [jira] [Created] (FLINK-41366) Support disabling automatic column addition in the Fluss pipeline sink Xiaobing Fang (Jira) via dev
• [jira] [Created] (FLINK-41363) Make ALTER TABLE ADD statements idempotent Muhammad (Jira) via dev
• [jira] [Created] (FLINK-41365) Remove queue based polling from DDB Connector Abhi Gupta (Jira) via dev
  • Re: [jira] [Created] (FLINK-41365) Remove queue based polling from DDB Connector 李恩健 via dev
• [jira] [Created] (FLINK-41364) Web dashboard: Poll checkpoint stats in the Checkpoints page and flag new data on Refresh Purushottam Sinha (Jira) via dev
• [jira] [Created] (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 dev
• [jira] [Created] (FLINK-41360) 'raw.line-delimiter' leaves a U+FEFF on each value in UTF-16, does not unescape '\n' and splits on an empty value Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41359) ORC format: filter push-down on a DOUBLE column drops rows when the column holds NaN (orc-core 1.5.6, ORC-629) Yaoxuan Wu (Jira) via dev
• [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 dev
• [RESULT][VOTE] FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen
• [jira] [Created] (FLINK-41357) FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen (Jira) via dev
• [jira] [Created] (FLINK-41356) Support early fire in the async state interval join Aaron He (Jira) via dev
• Review request for FLINK-25453 and continuation of FLINK-23598 Zhe Wang
• [jira] [Created] (FLINK-41326) chore: update JOSDK to v5.6.3 Attila Mészáros (Jira) via dev
• [jira] [Created] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets Luo Zhengjie (Jira) via dev
• [Review Request] Web UI job submission and Show Plan issues — FLINK-41303 / FLINK-39310 刘镕通 via dev
• [jira] [Created] (FLINK-41350) A materialized table left SUSPENDED by a failed table conversion cannot be resumed Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41335) Release Testing: Verify FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41334) SQL Gateway JSON results and the JDBC driver cannot return a UUID column Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41341) Add VARIANT_ARRAY_APPEND and TRY_VARIANT_ARRAY_APPEND Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41343) Add Variant#normalize() and VARIANT_NORMALIZE Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41338) Add an edit API to VariantBuilder Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41333) MIN, MAX and streaming COUNT(DISTINCT) reject the UUID type Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41351) Release Testing: Verify FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib (Jira) via dev
  • Re:[jira] [Created] (FLINK-41351) Release Testing: Verify FLIP-578: In-place Table to Materialized Table conversion z_mmG
• [jira] [Created] (FLINK-41344) Add VARIANT_CONTAINS with a shared value-equality rule Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41339) Add VARIANT_SET, VARIANT_INSERT and their TRY_ forms Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41349) Document building and editing VARIANT values in Java Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41348) Merge nested VARIANT modification calls into one pass Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41336) FLIP-618: Edit, Inspect and Build VARIANT Values Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41342) Add VARIANT_STRIP_NULLS Ramin Gharib (Jira) via dev
• [DISCUSS] Apache Flink 1.20.6, 2.2.2 and 2.3.1 release plan Rui Fan
  • Re: [DISCUSS] Apache Flink 1.20.6, 2.2.2 and 2.3.1 release plan Purushottam Sinha
  • Re: [DISCUSS] Apache Flink 1.20.6, 2.2.2 and 2.3.1 release plan Rui Fan
• [jira] [Created] (FLINK-41316) Publish built-in function pages as Markdown with an llms.txt index Ramin Gharib (Jira) via dev
• [DISCUSS] Planner-level GEOGRAPHY type in Apache Calcite David Chaava via dev
• [jira] [Created] (FLINK-41321) A join on an ARRAY<MAP> key returns no rows, although the same two maps compare equal with = sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41322) JSON_QUOTE does not round-trip a character outside the BMP through JSON_UNQUOTE sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41317) [pipeline-connector/kafka] NullPointerException when serializing REPLACE events in canal-json and debezium-json kim (Jira) via dev
• [jira] [Created] (FLINK-41324) COLLECT returns extra multiset entries when mini-batch is enabled, and the result varies between runs sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format Ramin Gharib (Jira) via dev
• [jira] [Created] (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 dev
• [jira] [Created] (FLINK-41319) REGEXP_INSTR disagrees with POSITION, LOCATE and INSTR for characters outside the BMP sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41318) ASCII returns a negative number for characters outside US-ASCII sepuri sai krishna (Jira) via dev
• [jira] [Created] (FLINK-41315) Add the page structure for built-in function docs Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41299) Watermark alignment deadlocks checkpoints after source subtasks finish Chen Zhang (Jira) via dev
• [jira] [Created] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via dev
• [jira] [Created] (FLINK-41307) PyFlink TableResult.collect() changes TIMESTAMP values in a DST gap or before 1902 (converted through the JVM and Python local time zones) Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41313) Fluss pipeline source does not unsubscribe dropped or expired partitions liting liu (Jira) via dev
• [jira] [Created] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via dev
• [FLINK-31040] Requesting assignment and review: CEP loses partial matches before a trailing notFollowedBy Mohammad
• [jira] [Created] (FLINK-41296) fullWindowPartition().mapPartition() corrupts output: the end-of-input watermark is emitted on the task thread while the UDF thread is still emitting records Paul King (Jira) via dev
• [jira] [Created] (FLINK-41306) Parquet format writes TIMESTAMP values before 1970 with a fractional second one second late (INT96, parquet.utc-timezone=false); Flink cannot read them back Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41302) Expose canary reconcile latency as a measure of reconciliation pool saturation Dennis-Mircea Ciupitu (Jira) via dev
• [jira] [Created] (FLINK-41297) PackagedProgramApplication never closes the PackagedProgram submitted via REST run-application Bharath Reddy Gunapati (Jira) via dev
• [jira] [Created] (FLINK-41311) Unresponsive JobManager is never reported because READY is set without a REST check Dennis-Mircea Ciupitu (Jira) via dev
• [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Zhanghao Chen
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink yue ma
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Dian Fu
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Geng Biao
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Xingbo Huang
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Yong Fang
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Yuepeng Pan via dev
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Purushottam Sinha
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Shengkai Fang
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Peter Huang
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Leonard Xu
  • Re: [VOTE] FLIP-608: Flink on Ray - Ray Resource Backend For Flink Rui Fan
• [jira] [Created] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via dev
• [jira] [Created] (FLINK-41309) Expose the JobManager deployment status and the resource age as kubectl printer columns Dennis-Mircea Ciupitu (Jira) via dev
• [jira] [Created] (FLINK-41308) Web dashboard: TaskManager Metrics "Netty Shuffle Buffers" Available/Total are always blank Purushottam Sinha (Jira) via dev
• [jira] [Created] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via dev
• [jira] [Created] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41301) Throw TableRuntimeException for every failed cast from VARIANT Ramin Gharib (Jira) via dev
• [jira] [Created] (FLINK-41300) [cdc][mysql] MySQL pipeline connector fails the job when a GEOMETRY/POLYGON value cannot be exported to GeoJSON VISHAL B (Jira) via dev
• [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 dev
• [jira] [Created] (FLINK-41294) PyFlink batch: pandas UDAF over a RANGE frame with CURRENT ROW or n PRECEDING / FOLLOWING reads the ORDER BY key as TIMESTAMP(3) and gets wrong frames for INT and DECIMAL keys Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41295) PyFlink: Python UDFs receive TIMESTAMP values before 1901-12-13 or after 2038-01-19 as wrong dates (int32 seconds in the Cython TimestampCoderImpl) Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41292) PyFlink batch: pandas UDAF in an aggregation without GROUP BY returns no row for an empty input Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41290) PyFlink streaming: Python UDTF in a lateral join loses the row kind of the input (NULL-padded LEFT JOIN rows; every row in thread mode) Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41289) Run canary health checks only with the health probe enabled, on one named thread Dennis-Mircea Ciupitu (Jira) via dev
• [jira] [Created] (FLINK-41288) Recreating a canary resource leaves duplicate health check loops running Dennis-Mircea Ciupitu (Jira) via dev
• [2.4 Release] Request for Cross-team Testing Support Chanhae Oh
• [jira] [Created] (FLINK-41286) Release Testing: Verify FLIP-585: Introduce Lazy Loading for HistoryServer chenzihao (Jira) via dev
• [jira] [Created] (FLINK-41287) Batch sliding (HOP) group window loses the windows of the last pane when an empty window precedes it (SortWindowAggregate) Yaoxuan Wu (Jira) via dev
• [jira] [Created] (FLINK-41285) Release Testing: Verify FLIP-584: Support Pluggable Storage Backend for HistoryServer chenzihao (Jira) via dev
• [jira] [Created] (FLINK-41284) REST: Application endpoints return 500 instead of 404 for unknown or expired applications Purushottam Sinha (Jira) via dev
• [jira] [Created] (FLINK-41278) Distinguish DEFAULT arguments from explicit NULL during type inference dylanhz (Jira)
• [jira] [Created] (FLINK-41279) Support the PostgreSQL-style :: cast operator Ramin Gharib (Jira)
• [DISCUSS] Which Java versions are you running Flink on? Martijn Visser
  • Re: [DISCUSS] Which Java versions are you running Flink on? Giannis Polyzos
  • Re: [DISCUSS] Which Java versions are you running Flink on? Andreas Bube via dev
  • Re: [DISCUSS] Which Java versions are you running Flink on? Zhanghao Chen
  • Re: [DISCUSS] Which Java versions are you running Flink on? Francis Altomare
  • Re: [DISCUSS] Which Java versions are you running Flink on? Yanquan Lv via dev
• [jira] [Created] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE or TIME returns a wrong value Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41283) Last-state upgrade fails when checkpointing is disabled and max checkpoint age is set Santwana Verma (Jira)
• [jira] [Created] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Anton Borisov (Jira)

• Earlier messages