dev  

Messages by Thread

• • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yun Gao
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Hang Ruan
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing weijie guo
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Junrui Lee
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Xu Huang
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Feng Jin
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gustavo de Morais
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Rui Fan
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yong Fang
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Peter Huang
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Dian Fu
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Hangxiang Yu
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Timo Walther
  • Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Ramin Gharib
• [jira] [Created] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
• Re: Java 25 Support Martijn Visser
  • Re: Java 25 Support Sergey Nuyanzin
  • Re: Java 25 Support Sergey Nuyanzin
• [jira] [Created] (FLINK-39719) TemporalRowTimeJoinOperator produces wrong results for late probe-side records Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39718) [pipeline][paimon] Paimon sink fails with distributed source when target table does not exist Ran Tao (Jira)
• Flink CEP: can CEP reliably implement "condition true for T minutes" ? rohit patil
  • Re: Flink CEP: can CEP reliably implement "condition true for T minutes" ? rohit patil
• [jira] [Created] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39716) ES timeout related config used the wrong time unit reswqa (Jira)
• [SUMMARY] Release 2.3 sync Hao Li
  • Re: [SUMMARY] Release 2.3 sync Yuepeng Pan
  • Re: [SUMMARY] Release 2.3 sync Keith Lee
  • [SUMMARY] Release 2.3 SYNC Yuepeng Pan
• [jira] [Created] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Mingliang Liu (Jira)
• [jira] [Created] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39709) Update documentation for native-s3-fs Samrat Deb (Jira)
• [jira] [Created] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 Mukul Gupta (Jira)
• State TTL support gap in DataStream API V2 (FLINK-34547) khertz11
• [jira] [Created] (FLINK-39706) Remove flink 2.1 testing from es connector main branch Weijie Guo (Jira)
• [jira] [Created] (FLINK-39705) Remove not needed ZooKeeper references from flink-connector-kafka Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Prashant Bhardwaj (Jira)
• [jira] [Created] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39702) Exclude netty 3.x from hadoop Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39701) Fix Concurrency Annotation in native-s3-fs Samrat Deb (Jira)
• [jira] [Created] (FLINK-39700) Fix name-based column matching in materialized table schema diff Arvid Heise (Jira)
• [jira] [Created] (FLINK-39699) Kafka connector CI failed on the main branch Rui Fan (Jira)
• [jira] [Created] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation Ruan Hang (Jira)
• [DISCUSS] FLINK-36456 — Datadog reporter: support DD_API_KEY env var Thierno BARRY via dev
  • RE: [DISCUSS] FLINK-36456 — Datadog reporter: support DD_API_KEY env var Thierno BARRY via dev
• [jira] [Created] (FLINK-39697) Update Pulsar connector to Flink 2.2.1 Fan Deng (Jira)
• [jira] [Created] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition Ran Tao (Jira)
• [jira] [Created] (FLINK-39695) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39694) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39692) Several catch blocks log the message but discard the captured exception Pavel Zeger (Jira)
• [jira] [Created] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules Pavel Zeger (Jira)
• [jira] [Created] (FLINK-39690) Use imgae from official hugo images Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39689) Standardize the place holders characters used in http-generic-json-url query creator to use {{ and }} David Radley (Jira)
• CVE-2026-35194: Apache Flink: Remote code execution via SQL injection in code generation Martijn Visser
• [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Gustavo de Morais
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Timo Walther
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join David Anderson
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Xingcan Cui
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join David Anderson
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Jark Wu
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Gustavo de Morais
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Hongshun Wang
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Hongshun Wang
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Leonard Xu
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Jark Wu
• [ANNOUNCE] Apache Flink 2.2.1 released Sergey Nuyanzin
• [jira] [Created] (FLINK-39688) Share a single PluginManager across operator and webhook startup Dennis-Mircea Ciupitu (Jira)
• [NOTICE] Removal of Apache Flink 1.13.0-1.13.5 from PyPI Sergey Nuyanzin
  • Re: [NOTICE] Removal of Apache Flink 1.13.0-1.13.5 from PyPI Sergey Nuyanzin
• [jira] [Created] (FLINK-39686) URI used as URL in SessionContext causes ArrayStoreException wangzhao (Jira)
• [jira] [Created] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException wangzhao (Jira)
• [jira] [Created] (FLINK-39685) Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39684) YAML PaimonWriter throws NullPointerException when handling REPLACE event Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39683) Publish the flink-cdc-dist jar to the Maven repository melin (Jira)
• [jira] [Created] (FLINK-39682) Unable to invoke TO_DATE with TIMESTAMP types Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39681) Bump flink to 2.2.1 Fan Deng (Jira)
• [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
  • Re: [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Roman Khachatryan
  • Re: [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Aleksandr Iushmanov
  • Re: [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Gabor Somogyi
  • Re: [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Ferenc Csaky
  • Re: [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
• [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Fabrizzio Chávez Tejada
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 David Radley
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 weijie guo
  • Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED Gen Luo (Jira)
• [jira] [Created] (FLINK-39679) Error with implicit casting Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-39678) Connection factory discovery through SPI Hao Li (Jira)
• [jira] [Created] (FLINK-39677) ARRAY_SORT fails at runtime with "Comparison method violates its general contract!" on arrays with duplicate elements Jim Hughes (Jira)
• [jira] [Created] (FLINK-39676) Add documentation for specifying Query Creators Nic Townsend (Jira)
• [jira] [Created] (FLINK-39675) http-generic-json-url query param configuration not required. David Radley (Jira)
• [jira] [Created] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client Alex Rovner (Jira)
• [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Arvid Heise via dev
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Kui Yuan
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Kui Yuan
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Kui Yuan
  • Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Kui Yuan
• [jira] [Created] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key Han Yin (Jira)
• [SUMMARY] Release 2.3 SYNC: In Creating RC0 and Cross-team Testing Yuepeng Pan
• [jira] [Created] (FLINK-39672) Update doc about Java Records Mingliang Liu (Jira)
• [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Hongshun Wang
  • RE: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 David Radley
  • RE: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 weijie guo
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Yuepeng Pan
  • Re: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39671) Adopt jackson-bom in flink-model-triton for unified version management Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, zookeeper, wiremock) Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39669) BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan Venkata krishnan Sowrirajan (Jira)
• [DISCUSS] Status of the Azure CI → GitHub Actions migration (FLINK-33901) Michele Guerriero
  • Re: [DISCUSS] Status of the Azure CI → GitHub Actions migration (FLINK-33901) Matthias Pohl via dev
• [jira] [Created] (FLINK-39668) Add get kafka offsets SQL table function Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39667) NGINX Ingress Retirement Dominik (Jira)
• [jira] [Created] (FLINK-39666) Fix TO_TIMESTAMP_LTZ multiple edge-case bugs in precision handling Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39665) Support ALTER MATERIALIZED TABLE ... SET REFRESH_MODE = FULL | CONTINUOUS conversion Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39664) Support ALTER MATERIALIZED TABLE ... SET FRESHNESS = ... conversion Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39662) Support ALTER MATERIALIZED TABLE ... SET ('k' = 'v') conversion Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39661) Support all converters for standalone ALTER MATERIALIZED TABLE statements Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39660) Kinesis Connector - Cascading failure in EFO subscription lifecycle Chenyuan Lee (Jira)
• [jira] [Created] (FLINK-39658) Upgrade flink-connector-hive from Flink 2.0-preview1 to Flink 2.0.x Jayesh Lalwani (Jira)
• [jira] [Created] (FLINK-39657) Migrate CatalogTable.of() to CatalogTable.newBuilder() Jayesh Lalwani (Jira)
• [jira] [Created] (FLINK-39659) Add JDK 17 test support with proper --add-opens documentation Jayesh Lalwani (Jira)
• [jira] [Created] (FLINK-39656) Remove legacy getTableFactory() override Jayesh Lalwani (Jira)
• [jira] [Created] (FLINK-39655) Remove deprecated CatalogLock and ManagedTable APIs (FLIP-346) Jayesh Lalwani (Jira)
• [RESULT][VOTE] Release 2.2.1, release candidate #3 Sergey Nuyanzin
• [ANNOUNCE] Apache Flink 2.1.2 released Sergey Nuyanzin
  • Re: [ANNOUNCE] Apache Flink 2.1.2 released Ramin Gharib
• [jira] [Created] (FLINK-39654) Add JDK 25 CI test lane Junqing Li (Jira)
• [jira] [Created] (FLINK-39653) [Connectors/Opensearch] Move to Flink to 2.0.0 - Fix Violations of ArchUnit architecture rule enforced in Flink 2.x Taranpreet Kaur (Jira)
• [RESULT][VOTE] Release 2.1.2, release candidate #2 Sergey Nuyanzin
• [ANNOUNCE] Apache Flink 2.0.2 released Sergey Nuyanzin
  • Re: [ANNOUNCE] Apache Flink 2.0.2 released Ramin Gharib
• [jira] [Created] (FLINK-39652) Improve documentation for regexp functions Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39651) REGEXP predicate does not validate literal regex patterns at plan time and logs errors on the hot path Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39650) REGEXP_REPLACE does not validate literal regex patterns at plan time, recompiles per record, and logs errors on the hot path Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39649) REGEXP_EXTRACT plan-time validation and hot-path log cleanup Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39648) Validate literal regex patterns at plan time and stop logging on the hot path for the regex function family Ramin Gharib (Jira)
• [DISSCUSS] FLIP-XXX: Async MongoDB Sink with Error Classification and Shared Connection Pool FeatZhang
  • Re: [DISSCUSS] FLIP-XXX: Async MongoDB Sink with Error Classification and Shared Connection Pool FeatZhang
• [jira] [Created] (FLINK-39647) Upgrade presto hive Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39646) Update flink-python-example to Flink 2.2 Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39645) HybridSourceReader.snapshotState() loses recovered splits when currentReader is null Chen Zhang (Jira)
  • Re: [jira] [Created] (FLINK-39645) HybridSourceReader.snapshotState() loses recovered splits when currentReader is null Chase Zhang
• [jira] [Created] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance Samrat Deb (Jira)
• [RESULT][VOTE] Release 2.0.2, release candidate #4 Sergey Nuyanzin
• [jira] [Created] (FLINK-39643) [docs] Fix and improve MongoDB connector documentation featzhang (Jira)
• [jira] [Created] (FLINK-39642) Fix Illegal argument error message Samrat Deb (Jira)
• [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer zihao chen
  • Re:[DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer 魏祚
  • Re: [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer zihao chen
  • Re: [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer Fan Deng
  • Re: [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer zihao chen
• [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
  • Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer Fan Deng
  • Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
  • Re:[DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer 魏祚
  • Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
  • Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
  • Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
• [jira] [Created] (FLINK-39641) Fix unstable position of the Rescales tab Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39640) Bump Flink 1.20.0 to 1.20.3 and upgrade maven-shade-plugin to 3.6.0 Jayesh Lalwani (Jira)
• [jira] [Created] (FLINK-39639) Split assignment accepted after source finished reading leads to silent data loss Piotr Nowojski (Jira)
• Help Needed for Release2.3: Confirm Cross-Team Testing for FLINK-39464 & FLINK-39461 Yuepeng Pan
• [jira] [Created] (FLINK-39638) Make codegen reuse result of JSON parse in JSON_VALUE, JSON_QUERY Sergey Nuyanzin (Jira)

• Earlier messages
• Later messages