dev

Messages by Date

2026/01/21 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/21 [jira] [Created] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs Martijn Visser (Jira)
2026/01/20 [jira] [Created] (FLINK-38954) Flink Benchmark Score Decreases After Upgrading JDK Versions of Flink Engine and User Program zhangxing (Jira)
2026/01/20 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
2026/01/20 JSON_STRING and helper utilities around VARIANT data type Swapna Marru
2026/01/20 [jira] [Created] (FLINK-38953) Cleanup configurations for SSL hostname verification Mate Czagany (Jira)
2026/01/20 [jira] [Created] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes Ferenc Csaky (Jira)
2026/01/20 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Maximilian Michels
2026/01/20 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/20 Re: [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor
2026/01/20 Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
2026/01/20 Re: [VOTE] FLIP-560: Application Capability Enhancement Lei Yang
2026/01/19 Re: [VOTE] FLIP-560: Application Capability Enhancement Rui Fan
2026/01/19 Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Leonard Xu
2026/01/19 Re: [VOTE] FLIP-560: Application Capability Enhancement Yuepeng Pan
2026/01/19 Re: [VOTE] FLIP-560: Application Capability Enhancement gyula . fora
2026/01/19 Re: [VOTE] FLIP-560: Application Capability Enhancement Zhu Zhu
2026/01/19 [VOTE] FLIP-560: Application Capability Enhancement Yi Zhang
2026/01/19 [jira] [Created] (FLINK-38951) Upgrade pemja to 0.5.6 Xuannan Su (Jira)
2026/01/19 Re: Kubernetes Operator 1.14.0 release planning Daniel Rossos via dev
2026/01/19 [jira] [Created] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses Sebastien Pereira (Jira)
2026/01/19 Re: Optional configuration parameters for better performance Rahul Teke
2026/01/19 Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Aleksandr Savonin
2026/01/19 [jira] [Created] (FLINK-38949) unpack_build_artifact.sh script speed improvement Tom Ho (Jira)
2026/01/19 [jira] [Created] (FLINK-38948) Document SINGLE_VALUE aggregate function Timo Walther (Jira)
2026/01/19 [jira] [Created] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error Roman Khachatryan (Jira)
2026/01/19 [jira] [Created] (FLINK-38946) Update Datadog API endpoint from app.datadoghq to api.datadoghq Ivan Stoiev (Jira)
2026/01/19 [jira] [Created] (FLINK-38945) [FLIP-561] Restructure Flink documentation Martijn Visser (Jira)
2026/01/19 [RESULT][VOTE] FLIP-561: Restructure Flink documentation Martijn Visser
2026/01/19 Re: [VOTE] FLIP-561: Restructure Flink documentation Martijn Visser
2026/01/19 RE: Re: [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor
2026/01/19 [jira] [Created] (FLINK-38944) Introduce a benchmark on adaptive partition selection for rescale partitioner and rebalance partitioner Yuepeng Pan (Jira)
2026/01/19 [jira] [Created] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
2026/01/19 [RESULT][VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
2026/01/19 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
2026/01/18 Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Rui Fan
2026/01/18 [jira] [Created] (FLINK-38942) Add documentation for async python scalar function Dian Fu (Jira)
2026/01/18 [jira] [Created] (FLINK-38941) Add Python building blocks for Async Python Scalar Function Dian Fu (Jira)
2026/01/18 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
2026/01/18 Re: [VOTE] FLIP-561: Restructure Flink documentation Zhe Wang
2026/01/18 Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
2026/01/18 [jira] [Created] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint Roman Khachatryan (Jira)
2026/01/18 [jira] [Created] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records Roman Khachatryan (Jira)
2026/01/17 [jira] [Created] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException Sergey Nuyanzin (Jira)
2026/01/17 Re: [DISCUSS] SSL hostname verification Gabor Somogyi
2026/01/17 [jira] [Created] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft Aleksandr Savonin (Jira)
2026/01/17 [DISCUSS] SSL hostname verification Mate Czagany
2026/01/16 [jira] [Created] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 liuerbao (Jira)
2026/01/16 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/16 Re: [VOTE] FLIP-561: Restructure Flink documentation David Anderson
2026/01/16 [jira] [Created] (FLINK-38935) HTTP Connector Fixe Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. David Radley (Jira)
2026/01/16 [jira] [Created] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored John Watson (Jira)
2026/01/16 Re:[VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Mang Zhang
2026/01/16 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner yuanfeng hu
2026/01/16 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection forStreamPartitioner Yuepeng Pan
2026/01/16 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection forStreamPartitioner o酷鱼o
2026/01/16 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Wei Zhong
2026/01/15 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Zhanghao Chen
2026/01/15 Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
2026/01/15 [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Rui Fan
2026/01/15 [jira] [Created] (FLINK-38933) python udx supports get_index_of_this_subtask Jacky Lau (Jira)
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner yuanfeng hu
2026/01/15 [jira] [Created] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay Zhanghao Chen (Jira)
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Zhanghao Chen
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Zhu Zhu
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
2026/01/15 [jira] [Created] (FLINK-38931) Support finish method in Python Table Function Dian Fu (Jira)
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Zhanghao Chen
2026/01/15 Re: Enhance Flink DynamicKafkaSource Hongshun Wang
2026/01/15 Re: Enhance Flink DynamicKafkaSource Hongshun Wang
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Zhanghao Chen
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Zander Matheson
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Yuepeng Pan
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Leonard Xu
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Xintong Song
2026/01/15 Enhance Flink DynamicKafkaSource Bowen Li
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Hao Li via dev
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Efrat Levitan
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation dylanhz
2026/01/15 [jira] [Created] (FLINK-38930) Filtering record before processing without spilling strategy Rui Fan (Jira)
2026/01/15 Re: [VOTE] FLIP-561: Restructure Flink documentation Ryan van Huuksloot via dev
2026/01/15 [VOTE] FLIP-561: Restructure Flink documentation Martijn Visser
2026/01/15 Re: [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
2026/01/15 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
2026/01/15 Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
2026/01/15 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/15 [jira] [Created] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING Dawid Wysakowicz (Jira)
2026/01/15 [RESULT][VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
2026/01/15 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
2026/01/15 [jira] [Created] (FLINK-38929) Add the ON CONFLICT configuration options Dawid Wysakowicz (Jira)
2026/01/15 [jira] [Created] (FLINK-38926) FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz (Jira)
2026/01/15 [jira] [Created] (FLINK-38927) Support ON CONFLICT in SqlParser Dawid Wysakowicz (Jira)
2026/01/15 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/15 [jira] [Created] (FLINK-38925) Update Matomo URL to the right domain Martijn Visser (Jira)
2026/01/15 [jira] [Created] (FLINK-38924) Redirect users to main page when encountering a 404 Martijn Visser (Jira)
2026/01/15 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
2026/01/15 [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
2026/01/15 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
2026/01/15 [jira] [Created] (FLINK-38921) osc support custom regx Jira
2026/01/15 Re: [DISCUSS] FLIP-560: Application Capability Enhancement gyula . fora
2026/01/15 [ANNOUNCE] Apache flink-connector-aws v5.1.0 released Ferenc Csaky
2026/01/15 [jira] [Created] (FLINK-38922) Cache Maven dependencies during documentation build Martijn Visser (Jira)
2026/01/15 Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
2026/01/15 [jira] [Created] (FLINK-38923) Pass configuration to operators/functions useInterruptibleTimers() Roman Khachatryan (Jira)
2026/01/15 Re: Kubernetes Operator 1.14.0 release planning Gyula Fóra
2026/01/14 Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
2026/01/14 Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
2026/01/14 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/14 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/14 [jira] [Created] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API Bowen Li (Jira)
2026/01/14 [jira] [Created] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Bowen Li (Jira)
2026/01/14 [jira] [Created] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink Bowen Li (Jira)
2026/01/14 [jira] [Created] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka Bowen Li (Jira)
2026/01/14 Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Bonnie Arogyam Varghese via dev
2026/01/14 Re: Kubernetes Operator 1.14.0 release planning Daniel Rossos via dev
2026/01/14 [jira] [Created] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 Stepan Stepanishchev (Jira)
2026/01/14 [jira] [Created] (FLINK-38910) mysql-cdc-connector datastrea support scan.binlog.newly-added-table.enabled config Thorne (Jira)
2026/01/14 [jira] [Created] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment Daniel Rossos (Jira)
2026/01/14 Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Lincoln Lee
2026/01/14 FLINK-38913 David Radley
2026/01/14 [jira] [Created] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final Mate Czagany (Jira)
2026/01/14 [jira] [Created] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) Martijn Visser (Jira)
2026/01/14 Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Zakelly Lan
2026/01/14 [jira] [Created] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with nested objects david radley (Jira)
2026/01/14 Re: [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Martijn Visser
2026/01/14 Kubernetes Operator 1.14.0 release planning Gyula Fóra
2026/01/13 [jira] [Created] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config Thorne (Jira)
2026/01/13 Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Feng Jin
2026/01/13 [jira] [Created] (FLINK-38909) Unable to delete S3 checkpoint due to presence of default file CHANHAE OH (Jira)
2026/01/13 Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Guowei Ma
2026/01/13 [jira] [Created] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently Mate Czagany (Jira)
2026/01/13 [jira] [Created] (FLINK-38907) Records lost using filtered autocreate mode Gio Gutierrez (Jira)
2026/01/13 [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
2026/01/13 Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Ramin Gharib
2026/01/13 Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
2026/01/13 Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Gustavo de Morais
2026/01/13 [ANNOUNCE] Apache Flink-shaded 21.0 released Martijn Visser
2026/01/13 [RESULT][VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
2026/01/13 Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
2026/01/12 Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Martijn Visser
2026/01/12 Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Sergey Nuyanzin
2026/01/12 [jira] [Created] (FLINK-38906) Polish YAML transform built-in functions Xiqian Yu (Jira)
2026/01/12 [jira] [Created] (FLINK-38905) YAML Transform to handle dirty data gracefully Xiqian Yu (Jira)
2026/01/12 Re: [DISCUSS] FLIP-561: Restructure Flink documentation Zhe Wang
2026/01/12 Re:[VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
2026/01/12 [jira] [Created] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) John Watson (Jira)
2026/01/12 [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
2026/01/12 Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
2026/01/12 Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Ahmed Hamdy
2026/01/12 [jira] [Created] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 Martijn Visser (Jira)
2026/01/12 Re: [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
2026/01/12 Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
2026/01/12 Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
2026/01/12 [RESULT][VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Ferenc Csaky
2026/01/12 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Ferenc Csaky
2026/01/12 [jira] [Created] (FLINK-38902) Add user instructions and usage documentation for FLIP-487. RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38901) Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38899) Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38898) Introduce the Rescales/Overview sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38892) Introduce the scheduler and type information of the target job in the /jobs/overview endpoint of the REST API RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API RocMarshal (Jira)
2026/01/12 [jira] [Created] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API RocMarshal (Jira)
2026/01/12 Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Leonard Xu
2026/01/12 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Hang Ruan
2026/01/12 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Leonard Xu
2026/01/12 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Sergey Nuyanzin
2026/01/12 RE: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan David Radley
2026/01/12 Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Sergey Nuyanzin
2026/01/11 Re: [DISCUSS] FLIP-560: Application Capability Enhancement Gyula Fóra
2026/01/11 Re: [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
2026/01/11 Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Archzi Lu
2026/01/11 [RESULT][VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
2026/01/11 Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
2026/01/11 Re:Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Xuyang
2026/01/11 Re:Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
2026/01/11 [jira] [Created] (FLINK-38891) Migrate MiniBatchIntervalInferRule Sergey Nuyanzin (Jira)
2026/01/11 [jira] [Created] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule Roman Rybak (Jira)
2026/01/11 RE: [VOTE] Release flink-shaded 21.0, release candidate #3 abhi Gupta
2026/01/11 [jira] [Created] (FLINK-38889) YAML Kafka sink connector supports serializing complex types yux (Jira)
2026/01/11 [jira] [Created] (FLINK-38888) YAML Pipeline supports item subscription of complex types yux (Jira)
2026/01/11 [jira] [Created] (FLINK-38887) YAML Transform module supports nested types yux (Jira)
2026/01/11 [jira] [Created] (FLINK-38886) Provide GenericRecordData in Pipeline public API yux (Jira)
2026/01/11 Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Xiqian YU
2026/01/10 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
2026/01/10 [jira] [Created] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children Sergey Nuyanzin (Jira)
2026/01/10 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Mate Czagany
2026/01/10 [jira] [Created] (FLINK-38884) Migrate IncrementalAggregateRule Roman Rybak (Jira)
2026/01/10 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Gabor Somogyi
2026/01/10 [DISCUSS] FLINK-38290 - Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated Royston Tauro
2026/01/09 Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Robert Metzger
2026/01/09 Re: Vendor-specific repos (re: flink-connector-aws) Rich Bowen
2026/01/09 Re: Vendor-specific repos (re: flink-connector-aws) tison