dev  

Messages by Thread

• [jira] [Created] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38834) Support modify column type DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization peiyu (Jira)
• [jira] [Created] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38831) The route configuration supports matching the first one peiyu (Jira)
• [jira] [Created] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-38829) Support rename column DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• Follow-up: ASF Account Application for Chen Rui rui chen
• [jira] [Created] (FLINK-38826) Add new ArgumentStrategy to support array with specified element type dylanhz (Jira)
• [jira] [Created] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• [jira] [Created] (FLINK-38824) Incorrect default values for primitive types dylanhz (Jira)
• [Result][Vote] FLIP-556: Introduce BITMAP Data Type dylanhz
• Vendor-specific repos (re: flink-connector-aws) Rich Bowen
• [jira] [Created] (FLINK-38823) Error running wide table task peiyu (Jira)
• [jira] [Created] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding featzhang (Jira)
• [jira] [Created] (FLINK-38821) Add TaskManager creation/deletion metrics to Active Resource Manager moonyoung (Jira)
• [jira] [Created] (FLINK-38820) Move ptf rules to rule folder Hao Li (Jira)
• [jira] [Created] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors Santwana Verma (Jira)
• [jira] [Created] (FLINK-38818) [posgtresql]Build createTableEventCache using TableSchemas from split and Make transform operator stateless ouyangwulin (Jira)
• [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Rui Fan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) yuanfeng hu
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) gongzhongqiang
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Matt Cuento
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) 董书佑
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) dylanhz
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Wei Zhong
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Leonard Xu
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Mang Zhang
  • Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) Yuepeng Pan
• [jira] [Created] (FLINK-38817) Out of order data seen while running tpc-ds queries Bonnie Varghese (Jira)
• [jira] [Created] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 david radley (Jira)
• [jira] [Created] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager dengxaing (Jira)
• [jira] [Created] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• [DISCUSS] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Zhu Zhu
  • Re: [DISCUSS] FLIP-560: Application Capability Enhancement Lei Yang
• [jira] [Created] (FLINK-38813) Enable Flink CDC connector to emit Debezium heartbeat events to downstream consumers Tejansh Rana (Jira)
• [jira] [Created] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• [VOTE] FLIP-556: Introduce BITMAP Data Type dylanhz
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Lincoln Lee
  • Re:Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Xuyang
  • Re: Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Yuepeng Pan
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Zhe Wang
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Ron Liu
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Hao Li via dev
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type Shengkai Fang
  • Re: [VOTE] FLIP-556: Introduce BITMAP Data Type dylanhz
• [jira] [Created] (FLINK-38811) Translate async function doc to Chinese Hao Li (Jira)
• [jira] [Created] (FLINK-38810) Use splittable timers in Interval Join Roman Khachatryan (Jira)
• Request to review GCP fix from FLINK-38225 Alex Nitavsky
• [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Martijn Visser
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Gabor Somogyi
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Tom Cooper
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Tom Cooper
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Leonard Xu
  • Re: [DISCUSS] Release flink-connector-parent 2.0 dropping JDK8 Hang Ruan
• [jira] [Created] (FLINK-38809) Update testcontainers to 2.0.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-38808) Support partition transforms in Iceberg sink ChaoFang (Jira)
• [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Pan Yuepeng
  • Re:[DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Mang Zhang
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
• [jira] [Created] (FLINK-38807) Add state SQL metadata type inference Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule yux (Jira)
• [jira] [Created] (FLINK-38805) Flaky test cases in JDBC connector. RocMarshal (Jira)
• [jira] [Created] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down Rui Fan (Jira)
• [jira] [Created] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. david radley (Jira)
• [jira] [Created] (FLINK-38802) DDL with duplicated keys in table options should fail Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository RocMarshal (Jira)
• [jira] [Created] (FLINK-38800) Add a maven submodule for Flink MCP server. ChaomingZhang (Jira)
• [jira] [Created] (FLINK-38799) Rename "LoadingWeight" to "ResourceUnitCount" Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases Avi Sanwal (Jira)
• [jira] [Created] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self Wren (Jira)
• [ANNOUNCE] Apache Flink Agents 0.1.1 released wenjin
• [jira] [Created] (FLINK-38796) UnresolvedMetadataColumn misses type during serializing to string Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38795) Do not use "--host" CLI param for standalone job Ferenc Csaky (Jira)
• [Proposal] Dual-Sync Checkpoint Plugin for Geo-Redundant Flink MUKUL GUPTA via dev
• [jira] [Created] (FLINK-38794) Update Kafka Connector to Kafka 4.1.1 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38793) Reuse result of functions if ther are used multiple times as input for other functions Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38792) Properly support configuration parameters for Flink CDC UDFs Hans-Peter Grahsl (Jira)
• [jira] [Created] (FLINK-38791) Add suppotr for ALTER MATERIALIZED TABLE MODIFY Sergey Nuyanzin (Jira)
• [RESULT][VOTE] Apache Flink Agents Release 0.1.1, release candidate #1 wenjin
• [jira] [Created] (FLINK-38790) Update Flink Connector Kafka to use Flink 2.2 Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38789) Consistently use AssertJ-related assertion APIs to implement assertions in the HTTP connector david radley (Jira)
• FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
• Minio going maintainace support only Samrat Deb
  • Re: Minio going maintainace support only Gabor Somogyi
  • Re: Minio going maintainace support only Ferenc Csaky
  • Re: Minio going maintainace support only Gabor Somogyi
• [jira] [Created] (FLINK-38788) flink-connector-mysql-cdc silently fails when unable to reconnect due to credentials rotation supreetha (Jira)
• [jira] [Created] (FLINK-38787) Add Metrics for FlinkBlueGreenDeployment resources Daniel Rossos (Jira)
• [jira] [Created] (FLINK-38786) Does support oracle-cdc partitioned table now ? laixiong (Jira)
• [jira] [Created] (FLINK-38785) Quotes removal doesn't remove them properly Muhammad (Jira)
• [jira] [Created] (FLINK-38784) Bump the version of Paimon flink to 1.3.1 Muhammad (Jira)
• [jira] [Created] (FLINK-38783) Caused by: java.util.ConcurrentModificationException huyuliang (Jira)
• [jira] [Created] (FLINK-38782) Mongodb CDC need a config to filter large size column Joekwal (Jira)
• [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor
  • Re: [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Zander Matheson
• [jira] [Created] (FLINK-38781) pass format options to the http response david radley (Jira)
• [jira] [Created] (FLINK-38780) Potential State Incompatibility Issue in Paimon Sink Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38779) YAML Pipeline router supports RegEx based routing Xiqian Yu (Jira)
  • Re: [jira] [Created] (FLINK-38779) YAML Pipeline router supports RegEx based routing Hari Krishnan U
• [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
• [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
• [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

• Earlier messages