dev  

Messages by Date

• 2026/09/08 [jira] [Created] (FLINK-40599) Allow pyarrow 21-25 (CVE-2026-25087) Florian Vazelle (Jira)
• 2026/09/08 [RESULT][VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
• 2026/09/08 [jira] [Created] (FLINK-40598) Complete and synchronize the Chinese Elastic Scaling documentation Zhe Wang (Jira)
• 2026/09/08 Re: SQL reserved keywords Martijn Visser
• 2026/09/08 [jira] [Created] (FLINK-40597) TypeExtractor rejects explicitly specified Types.UUID dylanhz (Jira)
• 2026/09/08 [jira] [Created] (FLINK-40595) Native S3 always aborts multipart uploads required for checkpoint recovery Mate Czagany (Jira)
• 2026/09/08 Re: [DISCUSS] FLIP-XXX : Remote Artifact Fetch for Session-Mode Job Submission Robert Metzger
• 2026/09/08 [jira] [Created] (FLINK-40594) Pipeline runtime silently truncates TIME(p > 3) to milliseconds tchivs (Jira)
• 2026/09/08 [jira] [Created] (FLINK-40593) Add batch recursive S3 deletes to native S3 connector Gabor Somogyi (Jira)
• 2026/09/08 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Liu Liu
• 2026/09/07 Re: FLINK-38023: PR #28161 code review request Avi Sanwal
• 2026/09/07 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Gustavo de Morais
• 2026/09/07 [jira] [Created] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication on Java 17 and 21 Jira
• 2026/09/07 Re: Review request: FLINK-39775 (Flink CDC, MySQL source) - PR #4418 Leonard Xu
• 2026/09/07 Re: Help with Jira account access — self-service reactivation returns HTTP 500 Leonard Xu
• 2026/09/07 [jira] [Created] (FLINK-40591) flink-sql-connector-pulsar does not shade protobuf,conflicts with hbase-client and other dependencies Hosowai (Jira)
• 2026/09/07 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Dian Fu
• 2026/09/07 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 Dennis-Mircea Ciupitu
• 2026/09/07 [jira] [Created] (FLINK-40590) Web dashboard: Update Angular and monaco-editor to latest patch versions Purushottam Sinha (Jira)
• 2026/09/07 Help with Jira account access — self-service reactivation returns HTTP 500 纪伟成
• 2026/09/07 [jira] [Created] (FLINK-40587) Recreating a FlinkDeployment throws an autoscaler exception Dennis-Mircea Ciupitu (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40589) SourceTopicIntegrityTest.testTopicIntegrityFailure is flaky: 2 second wait for the restored job to fail is too short on CI Martijn Visser (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40588) DynamicKafkaSourceReaderTest.testNotifyNoMoreSplits is flaky Martijn Visser (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40586) DynamicKafkaSourceEnumerator re-signals NoMoreSplits to already-finished readers on every reader registration, causing "OperatorEvent lost" task failover Martijn Visser (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Martijn Visser (Jira)
• 2026/09/07 Re: [DISCUSS] Promote Unified File Merging (FLIP-306) to PublicEvolving and Deprecate FLINK-26803 Zakelly Lan
• 2026/09/07 [jira] [Created] (FLINK-40581) Fix examples that cannot run against their declared Flink version Dennis-Mircea Ciupitu (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones Aleksandr Savonin (Jira)
• 2026/09/07 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Sergey Nuyanzin
• 2026/09/07 Re: [DISCUSS] Flink Kubernetes Operator support for the Flink 2.3 application layer Dale Lane
• 2026/09/07 [jira] [Created] (FLINK-40583) Filter operator keys on the remaining runtime config paths Dennis-Mircea Ciupitu (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40582) Add SCHEMA_OF_VARIANT and SCHEMA_OF_VARIANT_AGG built-in functions Ramin Gharib (Jira)
• 2026/09/07 Re: SQL reserved keywords P Sinha
• 2026/09/07 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Martijn Visser
• 2026/09/07 [jira] [Created] (FLINK-40580) Cast from VARIANT to a character string should render an object or array as JSON Ramin Gharib (Jira)
• 2026/09/07 SQL reserved keywords David Radley
• 2026/09/07 Re: [VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Piotr Nowojski
• 2026/09/07 [jira] [Created] (FLINK-40579) Weekly connector CI cancels all other branch lines on the first failure and exceeds the ASF 20-concurrent-jobs policy Martijn Visser (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40578) OVERLAY returns wrong results for several argument combinations sepuri sai krishna (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40577) Support ChangelogModes in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/09/07 [jira] [Created] (FLINK-40576) Exclude the transitive alluxio dependency from flink-s3-fs-presto Robert Metzger (Jira)
• 2026/09/06 [DISCUSS] Promoting flink-s3-fs-native from @Experimental to a mainstream S3FileSystem Samrat Deb
• 2026/09/06 [jira] [Created] (FLINK-40575) Support dynamic table unsubscription and re-subscription in Fluss pipeline source Xiaobing Fang (Jira)
• 2026/09/06 [jira] [Created] (FLINK-40574) Update SLF4J from 1.7.36 to 2.x Piotr Przybylski (Jira)
• 2026/09/06 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb David Anderson
• 2026/09/06 [jira] [Created] (FLINK-40573) Add removal of wildcards in spotless Sergey Nuyanzin (Jira)
• 2026/09/06 [jira] [Created] (FLINK-40572) Support dynamic model selection for AI functions Mao Jiayi (Jira)
• 2026/09/06 [jira] [Created] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Purushottam Sinha (Jira)
• 2026/09/06 [jira] [Created] (FLINK-40570) Speed up CI by cancelling jobs upon test completion Efrat Levitan (Jira)
• 2026/09/06 [jira] [Created] (FLINK-40569) Getting started with Flink shows 404 Sergey Nuyanzin (Jira)
• 2026/09/05 [jira] [Created] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Purushottam Sinha (Jira)
• 2026/09/05 [jira] [Created] (FLINK-40567) HistoryServerArchiveFetcherTest.testLazyFetchArchiveProactively is flaky on @TempDir cleanup Purushottam Sinha (Jira)
• 2026/09/05 [jira] [Created] (FLINK-40566) Daily benchmark failures for months Zakelly Lan (Jira)
• 2026/09/05 [ANNOUNCE] Apache Flink-shaded 22.0 released Sergey Nuyanzin
• 2026/09/05 [jira] [Created] (FLINK-40565) Bump netty to 4.2.17 Sergey Nuyanzin (Jira)
• 2026/09/05 [jira] [Created] (FLINK-40562) Preserve pathless claim mode across configuration round trips Aaron He (Jira)
• 2026/09/05 [jira] [Created] (FLINK-40564) [JUnit5 Migration] Migrate flink-statebackend-changelog tests to JUnit 5 and AssertJ gaurav kumar pandey (Jira)
• 2026/09/05 [jira] [Created] (FLINK-40563) Bump lombok to 1.18.48 Sergey Nuyanzin (Jira)
• 2026/09/05 Re: [DISCUSS] Promote Unified File Merging (FLIP-306) to PublicEvolving and Deprecate FLINK-26803 Rui Fan
• 2026/09/05 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 P Sinha
• 2026/09/05 [jira] [Created] (FLINK-40561) Migrate RocksDB state backend tests to JUnit 5 and AssertJ gaurav kumar pandey (Jira)
• 2026/09/04 [jira] [Created] (FLINK-40560) [Postgres] snapshot-only replication slot is never dropped unless the snapshot is instantaneous tchivs (Jira)
• 2026/09/04 Review request: FLINK-39775 (Flink CDC, MySQL source) - PR #4418 Spoorthi Basu
• 2026/09/04 [jira] [Created] (FLINK-40559) Application mode silently ignores the --claimMode / --restoreMode command-line option Aaron He (Jira)
• 2026/09/04 [jira] [Created] (FLINK-40558) Apply in-place scaling only on SCALE spec diff type Dennis-Mircea Ciupitu (Jira)
• 2026/09/04 [SUMMARY] Flink 2.4 Release Sync - 04.09.26 Mika Naylor
• 2026/09/04 [jira] [Created] (FLINK-40557) Make operation column optional in TO_CHANGELOG output Ferenc Csaky (Jira)
• 2026/09/04 [jira] [Created] (FLINK-40556) Support UUID value literals in the Table API Ramin Gharib (Jira)
• 2026/09/04 [jira] [Created] (FLINK-40553) Corrupted job-local HA data causes cluster-wide failover Matthias Pohl (Jira)
• 2026/09/04 [PR] [hotfix] Fix image name in README [flink-ci-docker] via GitHub
• 2026/09/04 Re: [PR] [hotfix] Fix image name in README [flink-ci-docker] via GitHub
• 2026/09/04 [jira] [Created] (FLINK-40554) Handle errors during JobGraph recovery Matthias Pohl (Jira)
• 2026/09/04 [jira] [Created] (FLINK-40555) Handle errors during JobResultStore entry retrieval Matthias Pohl (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40552) Support ordered asynchronous execution for YAML Transform Mao Jiayi (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40551) FileMergingChannelStateITCase is very flaky Sergey Nuyanzin (Jira)
• 2026/09/03 [PR] [FLINK-40548][ci] Bump ubunt to 24.04 [flink-ci-docker] via GitHub
• 2026/09/03 [jira] [Created] (FLINK-40549) Split level metrics leak the closed metricGroup on split finish Efrat Levitan (Jira)
• 2026/09/03 Re: [PR] [FLINK-40548][ci] Bump ubuntu to 24.04 [flink-ci-docker] via GitHub
• 2026/09/03 [jira] [Created] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup Purushottam Sinha (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40548) Bump ubuntu to 24.04 in flink-ci-docker Sergey Nuyanzin (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40547) Add "Interpreting Flink's SQL Changelog" concepts page Gustavo de Morais (Jira)
• 2026/09/03 [DISCUSS] Promote Unified File Merging (FLIP-306) to PublicEvolving and Deprecate FLINK-26803 Zakelly Lan
• 2026/09/03 [jira] [Created] (FLINK-40546) Automatically extract java.util.UUID as the UUID type in the DataStream API Ramin Gharib (Jira)
• 2026/09/03 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Cole Bailey via dev
• 2026/09/03 Re: [VOTE] FLIP-609: Type Inference for Python User Defined Functions Timo Theusner
• 2026/09/03 [VOTE] FLIP-609: Type Inference for Python User Defined Functions Mika Naylor
• 2026/09/03 [jira] [Created] (FLINK-40543) Race condition and ConcurrentModificationException in MockSplitEnumeratorContext.getSentSourceEvent() Sylwester Lachiewicz (Jira)
• 2026/09/03 Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Dian Fu
• 2026/09/03 [jira] [Created] (FLINK-40545) Add parseJson() and tryParseJson() Table API expression methods Ramin Gharib (Jira)
• 2026/09/03 [jira] [Created] (FLINK-40544) Add raw format support for UUID type Ramin Gharib (Jira)
• 2026/09/03 Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Mika Naylor
• 2026/09/03 Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Mika Naylor
• 2026/09/03 Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• 2026/09/02 Re: [VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Efrat Levitan
• 2026/09/02 Re: Re: [DISCUSS] Cluster overhead/waste in large shared Flink clusters Zhe Wang
• 2026/09/02 [jira] [Created] (FLINK-40542) Kubernetes Operator: session cluster deleted when running jobs can't be queried Purushottam Sinha (Jira)
• 2026/09/02 [jira] [Created] (FLINK-40540) Put the rule's reason first in the planner's "Cannot generate a valid execution plan" message Martijn Visser (Jira)
• 2026/09/02 Re: [VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Ryan van Huuksloot via dev
• 2026/09/02 Re: [VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Roman Khachatryan
• 2026/09/02 Re: [VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
• 2026/09/02 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
• 2026/09/02 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
• 2026/09/02 [jira] [Created] (FLINK-40539) Redact sensitive values in SET; and session config responses Gabor Somogyi (Jira)
• 2026/09/02 [VOTE] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
• 2026/09/02 [jira] [Created] (FLINK-40541) LATERAL SNAPSHOT join rejects a valid build-side watermark when it is declared on a column hidden by the column-expansion strategy Fabian Hueske (Jira)
• 2026/09/02 [jira] [Created] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic Jira
• 2026/09/02 [jira] [Created] (FLINK-40537) IDEA should load project with java from source.java.version Sergey Nuyanzin (Jira)
• 2026/09/02 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Gustavo de Morais
• 2026/09/01 [jira] [Created] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+ Sergey Nuyanzin (Jira)
• 2026/09/01 [jira] [Created] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place Dennis-Mircea Ciupitu (Jira)
• 2026/09/01 [jira] [Created] (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)
• 2026/09/01 [DISCUSS] Flink Kubernetes Operator support for the Flink 2.3 application layer James Kan via dev
• 2026/09/01 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Samrat Deb
• 2026/09/01 [jira] [Created] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job Juliusz Nadberezny (Jira)
• 2026/09/01 Re: [DISCUSS] Planning Flink 2.4 Mika Naylor
• 2026/09/01 Re: [DISCUSS] Planning Flink 2.4 주수민
• 2026/09/01 [jira] [Created] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 Xiqian Yu (Jira)
• 2026/09/01 Re: [DISCUSS] Planning Flink 2.4 Rui Fan
• 2026/09/01 [jira] [Created] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled VISHAL B (Jira)
• 2026/08/31 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Efrat Levitan
• 2026/08/31 [jira] [Created] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Archit Goyal (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• 2026/08/31 [RESULT][VOTE] Release flink-shaded 22.0, release candidate #1 Sergey Nuyanzin
• 2026/08/31 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Sergey Nuyanzin
• 2026/08/31 [jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40527) Update flink-shaded to 22.0 Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Ramin Gharib (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string Rui Fan (Jira)
• 2026/08/31 Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Hao Li
• 2026/08/31 [jira] [Created] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier Rui Fan (Jira)
• 2026/08/31 Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Timo Theusner via dev
• 2026/08/31 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
• 2026/08/31 [jira] [Created] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
• 2026/08/31 RE: Re: [DISCUSS] Cluster overhead/waste in large shared Flink clusters Yanis Djeridi via dev
• 2026/08/31 [jira] [Created] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale Rui Fan (Jira)
• 2026/08/31 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Swapnal Varma
• 2026/08/31 [jira] [Created] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager Taranpreet Kaur (Jira)
• 2026/08/31 Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Martijn Visser
• 2026/08/31 Re: [DISCUSS] Planning Flink 2.4 Mika Naylor
• 2026/08/31 [jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Rango (Jira)
• 2026/08/31 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Aleksandr Iushmanov
• 2026/08/30 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Samrat Deb
• 2026/08/30 [jira] [Created] (FLINK-40513) Validate forward routing and optimize Fluss sink writer with bucket affinity Mao Jiayi (Jira)
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Santwana Verma via dev
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Sergey Nuyanzin
• 2026/08/30 [jira] [Created] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list Hongshun Wang (Jira)
• 2026/08/30 退订 林
• 2026/08/30 [jira] [Created] (FLINK-40511) Track and speed up slow integration tests (KafkaSinkITCase and friends) Sylwester Lachiewicz (Jira)
• 2026/08/30 Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Peter Huang
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Peter Huang
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Weiqing Yang
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Ahmed Hamdy
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Roman Khachatryan
• 2026/08/30 [jira] [Created] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Poorvank Bhatia
• 2026/08/30 Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb David Radley
• 2026/08/29 [ANNOUNCE] New Apache Flink Committer: Samrat Deb Robert Metzger
• 2026/08/29 [jira] [Created] (FLINK-40509) Move operator defaults out of the Helm chart so config.yaml carries only user-supplied content Gerk Elznik (Jira)
• 2026/08/29 [jira] [Created] (FLINK-40508) Support DB2 pipeline connector suntectec (Jira)
• 2026/08/28 Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Weiqing Yang
• 2026/08/28 [jira] [Created] (FLINK-40507) upgrade paimon to 2.0.0 peiyu (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/28 Re: [DISCUSS] Cluster overhead/waste in large shared Flink clusters Dennis-Mircea Ciupitu
• 2026/08/28 [jira] [Created] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 2× the periodic probe interval, contradicting the withIdleness documentation Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40502) scan.watermark.idle-timeout is silently ignored for connectors without watermark pushdown; SOURCE_WATERMARK() ignores idle-timeout entirely Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
• 2026/08/28 Re: [DISCUSS] Planning Flink 2.4 Rui Fan
• 2026/08/28 RE: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang David Radley
• 2026/08/28 [jira] [Created] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword Fabian Hueske (Jira)
• 2026/08/28 Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Yuepeng Pan
• 2026/08/28 [jira] [Created] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR Gustavo de Morais (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct) Arvid Heise (Jira)
• 2026/08/28 Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Sergey Nuyanzin
• 2026/08/27 Re:Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Xuyang
• 2026/08/27 Re: [DISCUSS] Model routing for ML_PREDICT (FLINK-39961) Purshotam Shah via dev
• 2026/08/27 Re: [DISCUSS] Planning Flink 2.4 Chanhae Oh
• 2026/08/27 Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Jark Wu
• 2026/08/27 Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Zander Matheson
• 2026/08/27 [jira] [Created] (FLINK-40495) Limit concurrent shared-state disposal to prevent JobManager I/O starvation Tianji Li (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps Ramin Gharib (Jira)
• 2026/08/27 Re: [DISCUSS] Use Project Lombok in Flink beyond tests Dennis-Mircea Ciupitu
• 2026/08/27 [jira] [Created] (FLINK-40486) Introduce the UUID logical type Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40487) CAST between UUID and STRING / BINARY(16) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40494) Document UUID and extended VARIANT type Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40491) Decode/accessor support in BinaryVariant for codes 17-20 Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40490) Runtime serialization and codegen for UUID Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40489) Add UUID_V4() & UUID_V7() functions Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40488) Comparison and ordering for UUID Ramin Gharib (Jira)

• Earlier messages