dev  

Messages by Thread

• [jira] [Created] (FLINK-38778) Web UI for applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38777) HistoryServer supports application archives Yi Zhang (Jira)
• [jira] [Created] (FLINK-38776) Incorrect auxiliary group field names dylanhz (Jira)
• [jira] [Created] (FLINK-38775) Flink 2.2: update reference data for Migration Tests Ruan Hang (Jira)
• [ANNOUNCE] Apache Flink 2.2.0 released Hang Ruan
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Ron Liu
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Jacky Lau
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Matt Cuento
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Hao Li via dev
  • Re: [ANNOUNCE] Apache Flink 2.2.0 released Weiqing Yang
• [jira] [Created] (FLINK-38774) Fixed incorrect handling of hidden directories when obtaining partition structure huyuliang (Jira)
• [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 wenjin
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Eugene
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Xintong Song
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Dian Fu
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Hao Li via dev
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Xuannan Su
  • Re: [VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 Zhu Zhu
• [jira] [Created] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context Hao Li (Jira)
• [jira] [Created] (FLINK-38772) CliClientITCase is broken in IDE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38771) Scalar arguments don't work with multi-table inputs Timo Walther (Jira)
• [jira] [Created] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Barak (Jira)
• Options to expose metrics in ResourceManagerDriver Alexis Sarda-Espinosa
• [jira] [Created] (FLINK-38769) Flink Cdc Parse Mysql data is uncompleted Hao Yu (Jira)
• nexmark project Roman Boyko
• [RESULT] [VOTE] Release 2.2.0, release candidate #2 Hang Ruan
• [jira] [Created] (FLINK-38768) Materialized table fails with validation exception in case of LATERAL TABLE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38767) Fix vector_search transformation Hao Li (Jira)
• [jira] [Created] (FLINK-38766) Add support for ALTER MATERIALIZED TABLE ADD support Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38765) Sink Upsert Materializer does not work with metadata columns Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE PJ Fanning (Jira)
• [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:[FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Gustavo de Morais
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: Re: Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder David Anderson
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
  • Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
• [jira] [Created] (FLINK-38763) Add REST API for JarRunApplication Yi Zhang (Jira)
• [jira] [Created] (FLINK-38762) Introduce SingleJobApplication Yi Zhang (Jira)
• [jira] [Created] (FLINK-38761) Support archiving applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38760) Add REST APIs for application query and cancellation Yi Zhang (Jira)
• [jira] [Created] (FLINK-38759) Refactor application mode with PackagedProgramApplication Yi Zhang (Jira)
• [jira] [Created] (FLINK-38758) Introduce PackagedProgramApplication Yi Zhang (Jira)
• [jira] [Created] (FLINK-38757) Introduce the base class for application Yi Zhang (Jira)
• [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Timo Walther
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ron Liu
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Arvid Heise
  • [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
• [jira] [Created] (FLINK-38756) Add support for ALTER MATERIALIZED TABLE ADD columns in parser Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38755) FLIP-549: Support Application Management Yi Zhang (Jira)
• [jira] [Created] (FLINK-38754) Unnecessary Yi Zhang (Jira)
• [jira] [Created] (FLINK-38753) Enrich more upsert keys by equiv expressions Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38752) Drop EquivalentExprShuttle Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38751) RowTimeRangeBoundedPrecedingFunction incorrectly cleans lastTriggeringTsState, may not discard expired data zzwqqq (Jira)
• [jira] [Created] (FLINK-38750) Validation of queries with functions erroneously invoked under select fails with StackOverflow Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38749) HTTP Connector : document the retry codes defaults david radley (Jira)
• [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Xintong Song
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Swapnal Varma
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Biao Geng
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Ron Liu
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Zakelly Lan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou xiangyu feng
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Guowei Ma
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Eugene Liu
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Lincoln Lee
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Xuyang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Weiqing Yang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Arvindkumar Akula
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Sergey Nuyanzin
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Ramin Gharib
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Hao Li via dev
  • Re: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou Shengkai Fang
  • RE: [ANNOUNCE] New Apache Flink Committer - Yunfeng Zhou wenjin
• [jira] [Created] (FLINK-38748) Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. RocMarshal (Jira)
• [jira] [Created] (FLINK-38747) Modify the annotation of RateLimiterStrategy/RateLimiter to @PublicEvolving Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38746) `RecordsWindowBuffer.addElement()` catches `EOFException` and retries recursively, causing StackOverflowError Rui Fan (Jira)
• [jira] [Created] (FLINK-38745) Set rows-per-second to Long.MAX to avoid limiting qps in production Liu (Jira)
• [jira] [Created] (FLINK-38744) Split PolarDB-X CDC connector from MySQL CDC Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38743) Change the connector name and identifiers so it does not clash with the getindata connector david radley (Jira)
• [jira] [Created] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) A S Rakesh Krishna (Jira)
• [jira] [Created] (FLINK-38741) MODIFY COLUMN position change events are ignored causing schema evolution failure cheng qian (Jira)
• [VOTE] Release 2.2.0, release candidate #2 Hang Ruan
  • Re: [VOTE] Release 2.2.0, release candidate #2 Leonard Xu
  • Re: [VOTE] Release 2.2.0, release candidate #2 Xiqian YU
  • Re: [VOTE] Release 2.2.0, release candidate #2 Hao Li via dev
  • Re: [VOTE] Release 2.2.0, release candidate #2 Lincoln Lee
  • Re: [VOTE] Release 2.2.0, release candidate #2 Yuepeng Pan
  • Re: [VOTE] Release 2.2.0, release candidate #2 Ron Liu
  • Re: [VOTE] Release 2.2.0, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release 2.2.0, release candidate #2 Gabor Somogyi
• [jira] [Created] (FLINK-38740) STDDEV related functions may produce invalid results dylanhz (Jira)
• [DISCUSS] Flink 2.x potential bug: pipeline.jobvertex-parallelism-overrides ignored Barak Bar-On
  • Re: [DISCUSS] Flink 2.x potential bug: pipeline.jobvertex-parallelism-overrides ignored Gyula Fóra
  • Re: [DISCUSS] Flink 2.x potential bug: pipeline.jobvertex-parallelism-overrides ignored Gyula Fóra
  • Re: [DISCUSS] Flink 2.x potential bug: pipeline.jobvertex-parallelism-overrides ignored Barak Bar-On
• [jira] [Created] (FLINK-38739) Drop unused SqlAlterTableAddConstraint Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38738) Don't overwrite transformation names by advanced ScanProviders Arvid Heise (Jira)
• Propose an Avro format optional schema David Radley
  • FW: Propose an Avro format optional schema David Radley
• [jira] [Created] (FLINK-38737) Introducing fallback keys can cause validateFactoryOptions to fail Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38736) Update the version of StarRocks dependency to avoid checkpoint hangs Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38735) ProcTimeCommitTrigger restore issue without state Naijie Liu (Jira)
• [jira] [Created] (FLINK-38734) Add option to customize update set expression when doing upserts with table sink Nikola Stanisavljevic (Jira)
• [jira] [Created] (FLINK-38733) Allow more dynamic splitter on JdbcSource Jira
• [jira] [Created] (FLINK-38732) Enable the stale bot for the JDBC connector david radley (Jira)
• [jira] [Created] (FLINK-38731) Add support for MULTI_JOIN hint Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38730) Bump jdk version of Flink CDC to 11 Leonard Xu (Jira)
• [jira] [Created] (FLINK-38729) Bump Flink version of Flink CDC to 2.1 or 2.2 Leonard Xu (Jira)
• [jira] [Created] (FLINK-38728) fullWindowPartition().reduce() is not being chained Jacob Jona Fahlenkamp (Jira)
• [jira] [Created] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow RocMarshal (Jira)
• [jira] [Created] (FLINK-38726) Bump Fluss version to 0.8.0 Leonard Xu (Jira)
• [jira] [Created] (FLINK-38725) Flink avro gives Security Exception with flink-sql-avro.jar Karan Makhija (Jira)
• [jira] [Created] (FLINK-38724) Allow per-vertex configuration of scale-down.max-factor to support balanced partition consumption yuanfenghu (Jira)
• [VOTE] Release 2.2.0, release candidate #1 Hang Ruan
  • Re: [VOTE] Release 2.2.0, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 2.2.0, release candidate #1 Mate Czagany
  • Re: [VOTE] Release 2.2.0, release candidate #1 Hang Ruan
  • Re: [VOTE] Release 2.2.0, release candidate #1 Hang Ruan
• [jira] [Created] (FLINK-38723) Provide Flink Configuration in the Context when Building DataSink/DataSource Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38722) Update HBase version to 2.6.4 Mate Czagany (Jira)
• [jira] [Created] (FLINK-38721) Support vector search for es connector Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38720) Nested nullability might lead to class cast RexCall cannot be cast to class RexFieldAccess Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38719) Display the number of tasks on the TaskManagers page. RocMarshal (Jira)
• [jira] [Created] (FLINK-38718) Display the slots utilization on the TaskManagers page. RocMarshal (Jira)
• [jira] [Created] (FLINK-38717) Display the load status on the TaskManagers page. RocMarshal (Jira)
• [jira] [Created] (FLINK-38716) Describe the impact of slot.request.max-interval on balanced tasks scheduling. RocMarshal (Jira)
• [jira] [Created] (FLINK-38715) Balanced tasks scheduling is suboptimal in some extreme scenarios. RocMarshal (Jira)
• [jira] [Created] (FLINK-38714) Support to adjust log level for embedded mode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38713) Add document about python user-defined logging Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38712) Move away distribution from table schema Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38711) LicenseChecker not properly checking included artifacts Mate Czagany (Jira)
• [jira] [Created] (FLINK-38710) operator properties in FlinkDeployment are not taking effect Diego Lobba (Jira)
• [jira] [Created] (FLINK-38709) PythonFunction & AsyncFunction doesn't work well when taking the recursive field of composite type as input Dian Fu (Jira)
• [DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
  • Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type Lincoln Lee
  • Re:Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type Xuyang
  • Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
  • RE: [DISCUSS] FLIP-556 Introduce BITMAP Data Type David Radley
  • Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
  • Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
  • Re:[DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
  • Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type Lincoln Lee
  • Re: [DISCUSS] FLIP-556 Introduce BITMAP Data Type dylanhz
• [jira] [Created] (FLINK-38708) Support LLM bulk APIs to the ML_Predict Rahul Battacharya (Jira)
• [jira] [Created] (FLINK-38707) Enable vector search for some table source Hao Li (Jira)
• [jira] [Created] (FLINK-38706) Add more builtin ModelProviders Hao Li (Jira)
• [jira] [Created] (FLINK-38705) Add sync openai provider Hao Li (Jira)
• [jira] [Created] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mohsen Rezaei (Jira)
• Jdbc Connector Release for 2.0 Joao Boto
• [jira] [Created] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager when reporting metrics Zdenek Tison (Jira)
• [jira] [Created] (FLINK-38702) Make unparse in parser more reusable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38701) TO_TIMESTAMP_LTZ should validate literal format Dawid Wysakowicz (Jira)
• [ANNOUNCE] New Apache Flink Committer - Hongshun Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Hang Ruan
  • RE: [ANNOUNCE] New Apache Flink Committer - Hongshun David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Xiqian YU
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Geng Biao
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun gongzhongqiang
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Zakelly Lan
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Feng Jin
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Xuyang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Lincoln Lee
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun dylanhz
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Shengkai Fang
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Weiqing Yang
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Hongshun Wang
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Sergey Nuyanzin
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Ramin Gharib
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Hao Li via dev
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Zhe Wang
  • RE: [ANNOUNCE] New Apache Flink Committer - Hongshun wenjin
• [jira] [Created] (FLINK-38700) "kubernetes pyflink application test" failed Dian Fu (Jira)
• [jira] [Created] (FLINK-38699) Order the WebUI's Completed Job List by end time order Liu (Jira)
• [jira] [Created] (FLINK-38698) TaskInformation blobs accumulate without cleanup causing storage exhaustion ari (Jira)
• [jira] [Created] (FLINK-38697) TaskInformation blobs accumulate without cleanup causing storage exhaustion ari (Jira)
• [jira] [Created] (FLINK-38696) Refactor KafkaSinkITCase to not rely on custom RateLimiter implementation Martijn Visser (Jira)
• [jira] [Created] (FLINK-38695) The metric about left cache request count in DeltaJoinCache is wrong Xuyang Zhong (Jira)
• [SUMMARY] Flink 2.2 Release Sync 11/19/2025 Hang Ruan
  • Re: [SUMMARY] Flink 2.2 Release Sync 11/19/2025 Hao Li

• Earlier messages
• Later messages