dev  

Messages by Date

• 2026/06/09 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Yanquan Lv
• 2026/06/09 Re: [VOTE] Release 2.1.3, release candidate #2 Yunfeng Zhou
• 2026/06/09 Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
• 2026/06/09 [jira] [Created] (FLINK-39899) Flink SQL Window TVF didn't remove rowtime attribute from original rowtime field Chen Zhang (Jira)
• 2026/06/09 Re: [VOTE] Release 1.20.5, release candidate #2 Yunfeng Zhou
• 2026/06/09 Re: [VOTE] Release 2.3.0, release candidate #3 Samrat Deb
• 2026/06/09 Re: Re: [VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer Junrui Lee
• 2026/06/09 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Weiqing Yang
• 2026/06/09 Re: Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2026/06/09 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Gustavo de Morais
• 2026/06/09 [jira] [Created] (FLINK-39898) ProcessingTimeService timer callbacks delayed until checkpoint when mini-batch and unaligned checkpoints are enabled ion (Jira)
• 2026/06/09 Re: [VOTE] Release 1.20.5, release candidate #2 Sergey Nuyanzin
• 2026/06/09 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Hao Li
• 2026/06/09 [jira] [Created] (FLINK-39897) limit() without an order produces invalid SQL Mika Naylor (Jira)
• 2026/06/09 [jira] [Created] (FLINK-39896) FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava (Jira)
• 2026/06/09 Re: [VOTE] Release 1.20.5, release candidate #2 Martijn Visser
• 2026/06/09 [jira] [Created] (FLINK-39895) PyFlink tests fail on release-1.20: setuptools 82 removed pkg_resources, breaking the Beam Python harness Martijn Visser (Jira)
• 2026/06/09 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger zihao chen
• 2026/06/09 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
• 2026/06/09 [jira] [Created] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
• 2026/06/09 Re: [VOTE] Release 1.20.5, release candidate #2 Sergey Nuyanzin
• 2026/06/09 [jira] [Created] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter Efrat Levitan (Jira)
• 2026/06/09 [jira] [Created] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint Efrat Levitan (Jira)
• 2026/06/09 Re: [VOTE] Release 1.20.5, release candidate #2 Yunfeng Zhou
• 2026/06/09 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Ramin Gharib
• 2026/06/09 [jira] [Created] (FLINK-39891) Cancel orphaned session jobs on the session cluster before (re)submitting a FlinkSessionJob lrsb (Jira)
• 2026/06/09 Re: Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Martijn Visser
• 2026/06/09 [jira] [Created] (FLINK-39890) Autoscaler crashes with NumberFormatException computing observed scaling coefficient for idle vertices lrsb (Jira)
• 2026/06/09 Re: [VOTE] Release 1.20.5, release candidate #2 Sergey Nuyanzin
• 2026/06/08 Re: [VOTE] Release 1.20.5, release candidate #2 Dian Fu
• 2026/06/08 Re: Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2026/06/08 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2026/06/08 Re: [RESULT][VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2026/06/08 [jira] [Created] (FLINK-39889) Convert table sqlnode to operation Hao Li (Jira)
• 2026/06/08 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
• 2026/06/08 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Gyula Fóra
• 2026/06/08 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/08 Re: [VOTE] Release 2.1.3, release candidate #2 weijie guo
• 2026/06/08 Re: [VOTE] Release 2.3.0, release candidate #3 weijie guo
• 2026/06/08 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/08 Re: [VOTE] Release 2.3.0, release candidate #3 Sergey Nuyanzin
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Samrat Deb
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Yunfeng Zhou
• 2026/06/08 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Chanhae Oh
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Xintong Song
• 2026/06/08 Re: [VOTE] Release 2.3.0, release candidate #3 Xintong Song
• 2026/06/08 Re: [VOTE] Release 2.1.3, release candidate #2 Xintong Song
• 2026/06/08 Re: [VOTE] Release 1.20.5, release candidate #2 Xintong Song
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li weijie guo
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Shengkai Fang
• 2026/06/08 Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Yanquan Lv
• 2026/06/08 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
• 2026/06/08 [jira] [Created] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Jigar Bhati (Jira)
• 2026/06/08 [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Yuepeng Pan
• 2026/06/08 Re: [VOTE] Release 2.3.0, release candidate #3 Hao Li
• 2026/06/08 RE: [ANNOUNCE] New Apache Flink Committer - Hao Li David Radley
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Sergey Nuyanzin
• 2026/06/08 Re: [VOTE] Release 2.3.0, release candidate #3 Ferenc Csaky
• 2026/06/08 [jira] [Created] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails Ramin Gharib (Jira)
• 2026/06/08 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Yuepeng Pan
• 2026/06/08 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Yuepeng Pan
• 2026/06/08 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Xingcan Cui
• 2026/06/08 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger Martijn Visser
• 2026/06/08 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region Roman Khachatryan
• 2026/06/08 [VOTE] Release 2.1.3, release candidate #2 Yunfeng Zhou
• 2026/06/08 [VOTE] Release 1.20.5, release candidate #2 Yunfeng Zhou
• 2026/06/08 [jira] [Created] (FLINK-39886) Introduce ProcessSetTableOperator in PTF with Async State API Can Luo (Jira)
• 2026/06/08 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API Martijn Visser
• 2026/06/08 Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Shengkai Fang
• 2026/06/08 [jira] [Created] (FLINK-39885) Introduce ProcessSetTableOperator in PTF with Async State API Can Luo (Jira)
• 2026/06/08 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Gyula Fóra
• 2026/06/08 [jira] [Created] (FLINK-39884) Free up additional disk space for CI runs Martijn Visser (Jira)
• 2026/06/08 [ANNOUNCE] New Apache Flink Committer - Hao Li Robert Metzger
• 2026/06/08 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Sergey Nuyanzin
• 2026/06/08 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Lincoln Lee
• 2026/06/07 [jira] [Created] (FLINK-39883) Support broadcast state in PTFs Timo Walther (Jira)
• 2026/06/07 FLINK-38698: adaptive scheduler BLOB leak, proposed fix, requesting assignment Spoorthi Basu
• 2026/06/07 Re: [VOTE] Release 2.3.0, release candidate #3 Yuepeng Pan
• 2026/06/07 Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic dylanhz
• 2026/06/07 Re: Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Weiqing Yang
• 2026/06/07 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu
• 2026/06/07 Re: [VOTE] Release 1.20.5, release candidate #1 Yunfeng Zhou
• 2026/06/07 Re: [VOTE] Release 2.1.3, release candidate #1 Yunfeng Zhou
• 2026/06/07 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Jark Wu
• 2026/06/07 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Jark Wu
• 2026/06/07 Re:Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Xuyang
• 2026/06/07 Re: [SUMMARY] Release 2.3 SYNC - Pending on rc2 voting Yuepeng Pan
• 2026/06/07 Re: [DISCUSS] Reviving FLIP-202: Introducing ClickHouse Connector for Apache Flink Chanhae Oh
• 2026/06/07 [jira] [Created] (FLINK-39882) Parser can not parse unparsed polymorphic table functions with several table args Sergey Nuyanzin (Jira)
• 2026/06/07 Re: Re: [DISCUSS] FLIP-316: Introduce SQL Driver Chanhae Oh
• 2026/06/07 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• 2026/06/06 [jira] [Created] (FLINK-39881) [FKO] Add AI tooling disclosure section to the PR template Purushottam Sinha (Jira)
• 2026/06/06 [jira] [Created] (FLINK-39880) YARNSessionFIFOSecuredITCase fails for java25 Sergey Nuyanzin (Jira)
• 2026/06/06 [jira] [Created] (FLINK-39879) CheckpointAcknowledgeFailureITCase.testCheckpointAckFailure never CompletableFuture and hangs on Complete Martijn Visser (Jira)
• 2026/06/06 [jira] [Created] (FLINK-39878) [JUnit5 Migration] Migrate flink-sql-parser assertions to AssertJ Purushottam Sinha (Jira)
• 2026/06/06 [jira] [Created] (FLINK-39876) [JUnit5 Migration] Migrate flink-streaming-java assertions to AssertJ Purushottam Sinha (Jira)
• 2026/06/06 [jira] [Created] (FLINK-39877) [JUnit5 Migration] Migrate flink-runtime assertions to AssertJ Purushottam Sinha (Jira)
• 2026/06/06 [VOTE] Release 2.1.3, release candidate #1 Yunfeng Zhou
• 2026/06/05 [jira] [Created] (FLINK-39875) Restore thread interrupt status in ResultStore.processRecord() after catching InterruptedException Jubin Soni (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39874) NativeS3RecoverableFsDataOutputStream leaks a temp file when the commit-time part upload fails, and uses non-idempotent deletes Li Guo (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError() Jubin Soni (Jira)
• 2026/06/05 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler gyula . fora
• 2026/06/05 [jira] [Created] (FLINK-39872) Add `wrapInException` into allowed list Sergey Nuyanzin (Jira)
• 2026/06/05 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Ryan van Huuksloot via dev
• 2026/06/05 [DISCUSS] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
• 2026/06/05 [ANNOUNCE] Apache flink-connector-pulsar 4.2.0 released Ferenc Csaky
• 2026/06/05 [ANNOUNCE] Apache flink-connector-kafka 5.0.0 released Ferenc Csaky
• 2026/06/05 [jira] [Created] (FLINK-39871) MinioTestContainerTest fails on JDK 8 CI agents in a non-UTC timezone because testcontainers cannot parse the +08:00 Network.created timestamp Martijn Visser (Jira)
• 2026/06/05 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Vivek Jhaver
• 2026/06/05 Re: [VOTE] FLIP-579: LATERAL SNAPSHOT Join Gustavo de Morais
• 2026/06/05 Re: [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Rui Fan
• 2026/06/05 Re: [DISCUSS] Reviving FLIP-202: Introducing ClickHouse Connector for Apache Flink Robert Metzger
• 2026/06/05 Re: Request for Wiki Edit Access Ferenc Csaky
• 2026/06/05 Re: Confluence edit permissions Ferenc Csaky
• 2026/06/05 Re: [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• 2026/06/05 Re: The Flink blog Robert Metzger
• 2026/06/05 [VOTE] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
• 2026/06/05 [jira] [Created] (FLINK-39870) Validate literal regex delimiters at planning time for STR_TO_MAP Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39869) Validate literal charset at planning time for ENCODE and drop the runtime warning Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39868) Remove per-row logging from PARSE_URL and SUBSTRING runtime Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39867) Harden built-in scalar function runtime: remove hot-path logging and validate constant args Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39866) Remove dead KEYVALUE code from SqlFunctionUtils and StringCallGen Ramin Gharib (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable Martijn Visser (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39864) ArchUnit ITCase rule flags non-cluster unit tests in flink-core Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39863) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-connector-files Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39862) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-formats modules Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39861) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-filesystems modules Purushottam Sinha (Jira)
• 2026/06/05 [jira] [Created] (FLINK-39860) Reduce ArchUnit violations: production code must not call @VisibleForTesting methods Purushottam Sinha (Jira)
• 2026/06/05 [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
• 2026/06/04 Re: [DISCUSS] Move flink-ci-docker under Apache Ramin Gharib
• 2026/06/04 Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Yuepeng Pan
• 2026/06/04 Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Gen Luo
• 2026/06/04 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
• 2026/06/04 Re: [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Lincoln Lee
• 2026/06/04 [VOTE] Release 2.3.0, release candidate #3 Yuepeng Pan
• 2026/06/04 [jira] [Created] (FLINK-39859) Upgrade Calcite version to 1.41.0 Sergey Nuyanzin (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39858) RestClient.close() can leave in-flight request futures uncompleted, hanging the caller Martijn Visser (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39857) Upgrade Pekko to 1.6.0 Sergey Nuyanzin (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39856) Auto-derive a default transactionalIdPrefix for EXACTLY_ONCE from JobID when unset Aleksandr Savonin (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39855) Include JobID in the backchannel key (cross-job robustness) Aleksandr Savonin (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39854) Log JobID in KafkaCommitter Aleksandr Savonin (Jira)
• 2026/06/04 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
• 2026/06/04 [jira] [Created] (FLINK-39853) Upgrade Testcontainers to 2.0.5 and remove the JUnit 4 dependency from flink-autoscaler-plugin-jdbc Purushottam Sinha (Jira)
• 2026/06/04 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
• 2026/06/04 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/04 [jira] [Created] (FLINK-39852) Translate documentation to Chinese Ramin Gharib (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39851) Document table-to-materialized-table conversion Ramin Gharib (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39850) Launch the refresh job when converting a table to a materialized table Ramin Gharib (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39849) Convert a regular table to a materialized table in the planner Ramin Gharib (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39848) Add config option and Catalog API for table-to-materialized-table conversion Ramin Gharib (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39847) FLIP-578: Support in-place conversion of a table to a materialized table Ramin Gharib (Jira)
• 2026/06/04 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu
• 2026/06/04 [jira] [Created] (FLINK-39846) IPv6HostnamesITCase runs unconditionally and fails on AdaptiveScheduler after JUnit5 migration Martijn Visser (Jira)
• 2026/06/04 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Gustavo de Morais
• 2026/06/04 Confluence edit permissions David Chaava via dev
• 2026/06/04 [jira] [Created] (FLINK-39845) SavepointITCase.testStopWithSavepointFailsOverToSavepoint fails on AdaptiveScheduler after JUnit5 migration Martijn Visser (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39844) PostgreSQL CDC: filter table columns by schema name to fix LIKE-wildcard cross-schema column leakage Di Wu (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39843) Support Oracle CDC streaming with the XStream adapter tianfy (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39840) Oracle pipeline connector emits incomplete table identifiers for data and schema change events tianfy (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39841) Add an option to skip Oracle ANALYZE TABLE before incremental snapshot chunk planning tianfy (Jira)
• 2026/06/04 [jira] [Created] (FLINK-39842) Support timestamp startup mode for Oracle CDC by resolving timestamps to SCN tianfy (Jira)
• 2026/06/03 Request for Wiki Edit Access Garegin Kalashyan via dev
• 2026/06/03 [jira] [Created] (FLINK-39839) AsyncTableFunction supports user-defined timeout handling logic Yuan Kui (Jira)
• 2026/06/03 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Martijn Visser
• 2026/06/03 [jira] [Created] (FLINK-39838) Bump Flink version to 1.20.4 in flink-kubernetes-operator Purushottam Sinha (Jira)
• 2026/06/03 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/03 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Hongshun Wang
• 2026/06/03 [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Kui Yuan
• 2026/06/03 Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
• 2026/06/03 [jira] [Created] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Xin Gao (Jira)
• 2026/06/03 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Ryan van Huuksloot via dev
• 2026/06/03 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
• 2026/06/03 Re: [VOTE] Release 2.3.0, release candidate #2 Yuepeng Pan
• 2026/06/03 [jira] [Created] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard Yuepeng Pan (Jira)
• 2026/06/03 [RESULT][VOTE] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
• 2026/06/03 Re: [VOTE] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
• 2026/06/03 Re: [VOTE] Release 2.3.0, release candidate #2 David Anderson
• 2026/06/03 Re: [VOTE] Release 2.3.0, release candidate #2 Sergey Nuyanzin
• 2026/06/03 [SUMMARY] Release 2.3 SYNC - Pending on rc2 voting Yuepeng Pan
• 2026/06/03 [jira] [Created] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint Gen Luo (Jira)
• 2026/06/03 Re: [VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Gyula Fóra
• 2026/06/03 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Gyula Fóra
• 2026/06/03 Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
• 2026/06/03 Re: [DISCUSS] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• 2026/06/03 [VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
• 2026/06/03 [jira] [Created] (FLINK-39834) Oracle CDC may duplicate UNISTR expressions when UNISTR value contains || tianfy (Jira)
• 2026/06/03 [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• 2026/06/03 Re: [DISCUSS] Release Flink 2.1.3 weijie guo
• 2026/06/03 [DISCUSS] Release Flink 2.1.3 Yunfeng Zhou
• 2026/06/03 [VOTE] Release 1.20.5, release candidate #1 Yunfeng Zhou
• 2026/06/03 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yuan Mei
• 2026/06/03 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Guowei Ma
• 2026/06/03 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Yuepeng Pan
• 2026/06/03 Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Gyula Fóra
• 2026/06/03 Re: [DISCUSS] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Gyula Fóra
• 2026/06/03 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
• 2026/06/03 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Roman Khachatryan
• 2026/06/03 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
• 2026/06/03 [jira] [Created] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL SkylerLin (Jira)
• 2026/06/02 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu

• Earlier messages