dev
Thread
Date
Earlier messages
Later messages
Messages by Date
2025/04/06
[jira] [Created] (FLINK-37619) cdcpiple sink paimon meet IllegalArgumentException when add column
linqichen (Jira)
2025/04/06
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
weijie guo
2025/04/05
Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink
Yanquan Lv
2025/04/05
[jira] [Created] (FLINK-37618) Support PTFs INTERVAL argument
juntaozhang (Jira)
2025/04/05
Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink
Őrhidi Mátyás
2025/04/05
[jira] [Created] (FLINK-37589) Job submission via REST API is not thread safe
Ilya Soin (Jira)
2025/04/05
[jira] [Created] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
2025/04/05
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
2025/04/05
[jira] [Created] (FLINK-37538) Get Schame fail if tables.exclude contain them
linqigeng (Jira)
2025/04/05
[jira] [Created] (FLINK-37606) Blocklist timeout check may lost
Heart Zhou (Jira)
2025/04/05
Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
2025/04/05
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
2025/04/05
Re: Process table function scan operation in batch mode is not supported
Timo Walther
2025/04/05
PR backlog
David Radley
2025/04/05
2025/03/27 CHI Eastern time zone workgroup meeting minutes
David Radley
2025/04/05
[jira] [Created] (FLINK-37557) ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns
Dawid Wysakowicz (Jira)
2025/04/05
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
2025/04/05
[jira] [Created] (FLINK-37607) Blocklist timeout check may lost
Heart Zhou (Jira)
2025/04/05
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Ferenc Csaky
2025/04/05
[jira] [Created] (FLINK-37534) Add Liniting checks to all PRs
Thomas Cooper (Jira)
2025/04/05
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Zakelly Lan
2025/04/05
Executing PyFlink Cluster
Gulan, Jacob
2025/04/05
[ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yuan Mei
2025/04/05
[ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Dawid Wysakowicz
2025/04/05
[VOTE] FLIP-515: Dynamic Kafka Sink
Őrhidi Mátyás
2025/04/05
Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Pradeepta Choudhury
2025/04/05
[jira] [Created] (FLINK-37586) YAML pipeline supports passing extra options to UDFs
yux (Jira)
2025/04/05
[jira] [Created] (FLINK-37584) Bump assertj-core version from 3.23.1 to 3.27.3
Siddharth R (Jira)
2025/04/05
[VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
weijie guo
2025/04/05
Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink
Yanquan Lv
2025/04/05
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Gyula Fóra
2025/04/05
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
2025/04/05
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Yanfei Lei
2025/04/04
RE: Community review process improvement proposal
David Radley
2025/04/04
Re: [VOTE] FLIP-512: Add meta information to SQL state connector
gongzhongqiang
2025/04/04
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Zakelly Lan
2025/04/04
Re: [ANNOUNCE] New Apache Flink Committer - Sergey Nuyanzin
Alexey Leonov-Vendrovskiy
2025/04/04
Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)
Rui Fan
2025/04/04
[jira] [Created] (FLINK-37486) Promote release 2.0
Weijie Guo (Jira)
2025/04/04
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
yuanfeng hu
2025/04/04
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Jacky Lau
2025/04/04
[jira] [Created] (FLINK-37615) Port EnvironmentSettings.Builder#withSerializationContext
Dawid Wysakowicz (Jira)
2025/04/04
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Guowei Ma
2025/04/04
[jira] [Created] (FLINK-37531) Respect the design of chain programming for RpcServiceBuilder
Jiaan Geng (Jira)
2025/04/04
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
2025/04/04
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
jufang he
2025/04/04
Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API
Yash Anand
2025/04/04
Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)
Andrea Sella
2025/04/04
[jira] [Created] (FLINK-37617) StateIterator should not have 2 onNext methods with almost the same signature
Gyula Fora (Jira)
2025/04/04
[jira] [Created] (FLINK-37611) Deflake ExactlyOnceKafkaWriterITCase#shouldAbortLingeringTransactions
Arvid Heise (Jira)
2025/04/04
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Hangxiang Yu
2025/04/04
[jira] [Created] (FLINK-37610) Running Over agg without OrderBy throws IndexOutOfBoundsException
Bonnie Varghese (Jira)
2025/04/04
[jira] [Created] (FLINK-37614) Make classloading for plannermodule more flexible
Martijn Visser (Jira)
2025/04/04
2025/04/03 CHI Western time zone workgroup meeting minutes
David Radley
2025/04/04
[jira] [Created] (FLINK-37616) PyFlink incorrectly unpickles Row fields
Mika Naylor (Jira)
2025/04/04
[jira] [Created] (FLINK-37613) Fix resource leak during transaction abortion
Arvid Heise (Jira)
2025/04/04
[jira] [Created] (FLINK-37612) Exception during initialization may leave operator unclosed
Arvid Heise (Jira)
2025/04/03
[jira] [Created] (FLINK-37609) Bump parquet libs to 1.15.1
Sergey Nuyanzin (Jira)
2025/04/03
[jira] [Created] (FLINK-37608) File sink supports to close buckets in parallel when snapshot
Hangxiang Yu (Jira)
2025/04/03
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Zakelly Lan
2025/04/03
Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Pradeepta Choudhury
2025/04/03
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Gabor Somogyi
2025/04/03
Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Xuyang
2025/04/03
Re: [ANNOUNCE] New Apache Flink Committer - Sergey Nuyanzin
Andriy Redko
2025/04/03
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Lincoln Lee
2025/04/03
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
gyula . fora
2025/04/03
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Yuepeng Pan
2025/04/03
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Shengkai Fang
2025/04/03
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Rui Fan
2025/04/03
Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Xuyang
2025/04/03
Unsubscribe me from flink user and flink dev mailing lists.
Titus Rakkesh
2025/04/02
Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink
Hongshun Wang
2025/04/02
[RESULT][VOTE] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/04/02
Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink
Hongshun Wang
2025/04/02
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Yuan Mei
2025/04/02
Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Han Yin
2025/04/02
[VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Han Yin
2025/04/02
[VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
weijie guo
2025/04/02
Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Hao Li
2025/04/02
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
2025/04/02
Re: [DISCUSS] FLIP-316: Introduce SQL Driver
Venkatakrishnan Sowrirajan
2025/04/02
[jira] [Created] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale
Arvid Heise (Jira)
2025/04/02
[jira] [Created] (FLINK-37603) FLIP-502: QueryOperation SQL Serialization customization
Dawid Wysakowicz (Jira)
2025/04/02
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Gabor Somogyi
2025/04/02
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Ryan van Huuksloot
2025/04/02
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Ferenc Csaky
2025/04/02
[jira] [Created] (FLINK-37604) Flink CDC pipeline composer doesn't assign UIDs to operators
Sergei Morozov (Jira)
2025/04/02
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
2025/04/02
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
2025/04/02
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gulan, Jacob
2025/04/02
Re: Executing PyFlink Cluster
Gabor Somogyi
2025/04/02
Re: Executing PyFlink Cluster
Andreas Bube
2025/04/02
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Shengkai Fang
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yash Anand
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Sergey Nuyanzin
2025/04/01
Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
yuanfeng hu
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yunfeng Zhou
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yuepeng Pan
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Hangxiang Yu
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Feifan Wang
2025/04/01
Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Rui Fan
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yanquan Lv
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Zhanghao Chen
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
xiangyu feng
2025/04/01
Re: [ANNOUNCE] Apache Flink 1.20.1 released
Alexander Fedulov
2025/04/01
[jira] [Created] (FLINK-37602) add objenesis to classloader.parent-first-patterns.default
Frens Jan Rumph (Jira)
2025/04/01
Re: Flink Kafka Connector: Release and Kafka client versions
Arvid Heise
2025/04/01
[jira] [Created] (FLINK-37601) Migrate from deprecated unirest-java to unirest-java-core
Siddharth R (Jira)
2025/04/01
RE: Pyflink improvements proposal
Hugo POLSINELLI
2025/04/01
[jira] [Created] (FLINK-37600) Add a pre-commit git hook for running linting checks
Thomas Cooper (Jira)
2025/04/01
Flink Kafka Connector: Release and Kafka client versions
Tom Cooper
2025/04/01
Re: Flink Kafka Connector: Release and Kafka client versions
Yanquan Lv
2025/04/01
Re: CHI: Add liiniting checks to all PRs
Tom Cooper
2025/04/01
Re: [DISCUSS] Elasticsearch v3.1 release
weijie guo
2025/04/01
[jira] [Created] (FLINK-37599) Consider on_time argument for column expansion
Timo Walther (Jira)
2025/04/01
[jira] [Created] (FLINK-37598) Support ListView and MapView in PTFs
Timo Walther (Jira)
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Rui Fan
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Rodrigo Meneses
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Lincoln Lee
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Ferenc Csaky
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
yue ma
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Junrui Lee
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Leonard Xu
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
weijie guo
2025/04/01
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yanfei Lei
2025/04/01
[jira] [Created] (FLINK-37597) Use ResourceGuard to make sure snapshot quit before ForSt dispose
Zakelly Lan (Jira)
2025/04/01
[jira] [Created] (FLINK-37591) Add Some PruneEmptyRules
Jacky Lau (Jira)
2025/03/31
[jira] [Created] (FLINK-37596) Close metric groups for finished splits
Efrat Levitan (Jira)
2025/03/31
[RESULT][VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
2025/03/31
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Lincoln Lee
2025/03/31
[jira] [Created] (FLINK-37595) Add Join remove rules.
Jacky Lau (Jira)
2025/03/31
[jira] [Created] (FLINK-37594) Remove targetColumns in DynamicTableSink/Sink/SinkRuntimeProviderContext
xiangyu feng (Jira)
2025/03/31
[jira] [Created] (FLINK-37593) Add some Reduce Expression Rules
Jacky Lau (Jira)
2025/03/31
[jira] [Created] (FLINK-37592) Update docs about SupportsTargetColumnWriting ability
xiangyu feng (Jira)
2025/03/31
[jira] [Created] (FLINK-37590) Update the code of Python modules to adapt to Flink 2.0's pyFlink
Yanquan Lv (Jira)
2025/03/31
Re: [DISCUSS] FLIP-518: Introduce a community review process
Doğuşcan Namal
2025/03/31
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Andrei Kaigorodov
2025/03/31
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Rui Fan
2025/03/31
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
2025/03/31
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/03/31
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
2025/03/31
[jira] [Created] (FLINK-37588) Flink Kubernetes Operator Parameter `jm-deployment.shutdown-ttl` does not take effect
yuanfenghu (Jira)
2025/03/31
Re:Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Yuepeng Pan
2025/03/30
[jira] [Created] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform
Yanquan Lv (Jira)
2025/03/30
[VOTE] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/03/30
Slack Invite
George Niece
2025/03/29
[jira] [Created] (FLINK-37585) The data of the newly added table cannot be read
jeff-zou (Jira)
2025/03/29
Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
gyula . fora
2025/03/28
Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Venkatakrishnan Sowrirajan
2025/03/28
Re: CHI: Add liiniting checks to all PRs
Neelesh Salian
2025/03/28
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Ahmed Hamdy
2025/03/28
[jira] [Created] (FLINK-37583) Upgrade Kafka Client version to 4.0.0
Thomas Cooper (Jira)
2025/03/28
Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink
Arvid Heise
2025/03/28
Re: CHI: Add liiniting checks to all PRs
Ferenc Csaky
2025/03/28
Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0
Arvid Heise
2025/03/28
Re: CHI: Add liiniting checks to all PRs
Arvid Heise
2025/03/28
[VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Ferenc Csaky
2025/03/28
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
2025/03/28
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/03/28
[jira] [Created] (FLINK-37577) Wait compaction only when table set deletion-vectors.enabled to true in PaimonWriter
Yanquan Lv (Jira)
2025/03/28
[jira] [Created] (FLINK-37582) Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram
Dawid Wysakowicz (Jira)
2025/03/28
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
2025/03/28
[jira] [Created] (FLINK-37581) Avoid duplicate calculation for total Flink memory
Jiaan Geng (Jira)
2025/03/28
Re: Process table function scan operation in batch mode is not supported
Shengkai Fang
2025/03/28
Re: [DISCUSS] FLIP-XXX: Checkpoint supports the Operator to customize asynchronous operation
Zakelly Lan
2025/03/28
Pyflink improvements proposal
Hugo POLSINELLI
2025/03/28
[jira] [Created] (FLINK-37580) Add checkpoint restore metric in in Flink Web UI
yanpengshi (Jira)
2025/03/28
Re: Process table function scan operation in batch mode is not supported
Gabor Somogyi
2025/03/28
[jira] [Created] (FLINK-37579) Avoid duplicate generate ResourceProfile
Jiaan Geng (Jira)
2025/03/28
[jira] [Created] (FLINK-37578) CDC Pipeline distributed schema evolution topology with bad internal state
yux (Jira)
2025/03/28
Re: Process table function scan operation in batch mode is not supported
Gyula Fóra
2025/03/28
Re: Process table function scan operation in batch mode is not supported
Gyula Fóra
2025/03/28
Re: Process table function scan operation in batch mode is not supported
Timo Walther
2025/03/28
[jira] [Created] (FLINK-37576) Batch job failed when submit JobGraph contains broadcast edge
Weijie Guo (Jira)
2025/03/27
[jira] [Created] (FLINK-37575) Simplify the code for creating netty shuffle environment.
Jiaan Geng (Jira)
2025/03/27
Re: Process table function scan operation in batch mode is not supported
Shengkai Fang
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
2025/03/27
[jira] [Created] (FLINK-37574) Add UDTF support in YAML pipeline transform expressions
yux (Jira)
2025/03/27
[jira] [Created] (FLINK-37528) Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields
Sai Sharath Dandi (Jira)
2025/03/27
Re: [DISCUSS] Release externalized Kudu connector
Mate Czagany
2025/03/27
Re: [DISCUSS] Release externalized Kudu connector
Márton Balassi
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/03/27
Process table function scan operation in batch mode is not supported
Gabor Somogyi
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Aleksandr Savonin
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Piotr Nowojski
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Gyula Fóra
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Martijn Visser
2025/03/27
[jira] [Created] (FLINK-37573) Deprecate Java 8 in Kafka
Arvid Heise (Jira)
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Lincoln Lee
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Yuepeng Pan
2025/03/27
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Leonard Xu
2025/03/27
[jira] [Created] (FLINK-37572) Shuffle Event by bucket and tableid to avoid data skew
Yanquan Lv (Jira)
2025/03/27
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Feng Jin
2025/03/27
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Roman Khachatryan
2025/03/27
[jira] [Created] (FLINK-37571) Last state upgrade mode broken for Flink 2.0
Gyula Fora (Jira)
2025/03/27
RE: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Gustavo de Morais
Earlier messages
Later messages