dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re:Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode
Xuyang
Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode
shuai xu
Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode
Ron Liu
Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode
shuai xu
Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode
shuai xu
[jira] [Created] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss
Keith Lee (Jira)
[jira] [Created] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache
Gabor Somogyi (Jira)
[VOTE] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Pradeepta Choudhury
Re: [VOTE] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Gyula Fóra
Re: [VOTE] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Rui Fan
Re: [VOTE] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Maximilian Michels
Re: [VOTE] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
Őrhidi Mátyás
[jira] [Created] (FLINK-37625) PyFlink Table API skips validation for Rows created with positional arguments
Mika Naylor (Jira)
[DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Wong, Daren
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Ahmed Hamdy
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Hong Liang
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Wong, Daren
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Keith Lee
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Wong, Daren
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Daren Wong
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Robert Metzger
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Daren Wong
Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Wong, Daren
RE: Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Daren Wong
RE: Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector
Daren Wong
[jira] [Created] (FLINK-37624) Support enableAsyncState and switch operator after datastream transformation
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37623) Async state support for `process()` in Datastream API
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37622) Exactly once Kafka sink does not produce any records in batch mode
Arvid Heise (Jira)
Kafka connector 4.0.0 release
Arvid Heise
Re: Kafka connector 4.0.0 release
Tom Cooper
Re: Kafka connector 4.0.0 release
Leonard Xu
Re: Kafka connector 4.0.0 release
Ferenc Csaky
[jira] [Created] (FLINK-37621) EnableAsyncState doesn't seem to do anything on DataStream API and misleading error message
Gyula Fora (Jira)
[jira] [Created] (FLINK-37620) ForSt Sync mode support remote storage and provide configurable options
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37619) cdcpiple sink paimon meet IllegalArgumentException when add column
linqichen (Jira)
[jira] [Created] (FLINK-37618) Support PTFs INTERVAL argument
juntaozhang (Jira)
[jira] [Created] (FLINK-37589) Job submission via REST API is not thread safe
Ilya Soin (Jira)
[jira] [Created] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
[jira] [Created] (FLINK-37538) Get Schame fail if tables.exclude contain them
linqigeng (Jira)
[jira] [Created] (FLINK-37606) Blocklist timeout check may lost
Heart Zhou (Jira)
PR backlog
David Radley
2025/03/27 CHI Eastern time zone workgroup meeting minutes
David Radley
[jira] [Created] (FLINK-37557) ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-37607) Blocklist timeout check may lost
Heart Zhou (Jira)
[jira] [Created] (FLINK-37534) Add Liniting checks to all PRs
Thomas Cooper (Jira)
Executing PyFlink Cluster
Gulan, Jacob
Re: Executing PyFlink Cluster
Andreas Bube
Re: Executing PyFlink Cluster
Gabor Somogyi
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gulan, Jacob
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Ferenc Csaky
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
[ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yuan Mei
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Zhanghao Chen
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yanquan Lv
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Feifan Wang
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Hangxiang Yu
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yuepeng Pan
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
jufang he
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yunfeng Zhou
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Sergey Nuyanzin
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yash Anand
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Shengkai Fang
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Jacky Lau
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Ryan van Huuksloot
Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Xuyang
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Zakelly Lan
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Gabor Somogyi
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Yanfei Lei
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
weijie guo
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Leonard Xu
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Junrui Lee
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
yue ma
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Ferenc Csaky
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Lincoln Lee
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Rodrigo Meneses
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Rui Fan
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
Guowei Ma
Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan
xiangyu feng
[ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Dawid Wysakowicz
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Zakelly Lan
Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Xuyang
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Rui Fan
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Shengkai Fang
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Yuepeng Pan
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Lincoln Lee
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
weijie guo
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Ferenc Csaky
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Arvid Heise
RE: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
David Radley
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Hong Liang
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Feifan Wang
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Gustavo de Morais
Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin
Yanquan Lv
[VOTE] FLIP-515: Dynamic Kafka Sink
Őrhidi Mátyás
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
gyula . fora
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Gabor Somogyi
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Maximilian Michels
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Alexander Fedulov
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Leonard Xu
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Őrhidi Mátyás
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Thomas Weise
[jira] [Created] (FLINK-37586) YAML pipeline supports passing extra options to UDFs
yux (Jira)
[jira] [Created] (FLINK-37584) Bump assertj-core version from 3.23.1 to 3.27.3
Siddharth R (Jira)
[VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
weijie guo
Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
Zakelly Lan
Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
Hongshun Wang
Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
Xiqian YU
Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
Yanquan Lv
Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
Yanquan Lv
Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1
weijie guo
[jira] [Created] (FLINK-37486) Promote release 2.0
Weijie Guo (Jira)
[jira] [Created] (FLINK-37615) Port EnvironmentSettings.Builder#withSerializationContext
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-37531) Respect the design of chain programming for RpcServiceBuilder
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37617) StateIterator should not have 2 onNext methods with almost the same signature
Gyula Fora (Jira)
[jira] [Created] (FLINK-37611) Deflake ExactlyOnceKafkaWriterITCase#shouldAbortLingeringTransactions
Arvid Heise (Jira)
[jira] [Created] (FLINK-37610) Running Over agg without OrderBy throws IndexOutOfBoundsException
Bonnie Varghese (Jira)
[jira] [Created] (FLINK-37614) Make classloading for plannermodule more flexible
Martijn Visser (Jira)
2025/04/03 CHI Western time zone workgroup meeting minutes
David Radley
[jira] [Created] (FLINK-37616) PyFlink incorrectly unpickles Row fields
Mika Naylor (Jira)
[jira] [Created] (FLINK-37613) Fix resource leak during transaction abortion
Arvid Heise (Jira)
[jira] [Created] (FLINK-37612) Exception during initialization may leave operator unclosed
Arvid Heise (Jira)
[jira] [Created] (FLINK-37609) Bump parquet libs to 1.15.1
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-37608) File sink supports to close buckets in parallel when snapshot
Hangxiang Yu (Jira)
Re: [ANNOUNCE] New Apache Flink Committer - Sergey Nuyanzin
Andriy Redko
Re: [ANNOUNCE] New Apache Flink Committer - Sergey Nuyanzin
Alexey Leonov-Vendrovskiy
Unsubscribe me from flink user and flink dev mailing lists.
Titus Rakkesh
[RESULT][VOTE] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
[VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Han Yin
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Yuan Mei
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Zakelly Lan
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Yanfei Lei
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Hangxiang Yu
Re: [VOTE] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State
Han Yin
[VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
weijie guo
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Zakelly Lan
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Yanquan Lv
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
weijie guo
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Yanquan Lv
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Xiqian YU
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Ferenc Csaky
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Hongshun Wang
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
Leonard Xu
Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1
weijie guo
Re: [DISCUSS] FLIP-316: Introduce SQL Driver
Venkatakrishnan Sowrirajan
[jira] [Created] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale
Arvid Heise (Jira)
[jira] [Created] (FLINK-37603) FLIP-502: QueryOperation SQL Serialization customization
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-37604) Flink CDC pipeline composer doesn't assign UIDs to operators
Sergei Morozov (Jira)
[jira] [Created] (FLINK-37602) add objenesis to classloader.parent-first-patterns.default
Frens Jan Rumph (Jira)
[jira] [Created] (FLINK-37601) Migrate from deprecated unirest-java to unirest-java-core
Siddharth R (Jira)
[jira] [Created] (FLINK-37600) Add a pre-commit git hook for running linting checks
Thomas Cooper (Jira)
Flink Kafka Connector: Release and Kafka client versions
Tom Cooper
Re: Flink Kafka Connector: Release and Kafka client versions
Yanquan Lv
Re: Flink Kafka Connector: Release and Kafka client versions
Arvid Heise
Re: Flink Kafka Connector: Release and Kafka client versions
Tom Cooper
[jira] [Created] (FLINK-37599) Consider on_time argument for column expansion
Timo Walther (Jira)
[jira] [Created] (FLINK-37598) Support ListView and MapView in PTFs
Timo Walther (Jira)
[jira] [Created] (FLINK-37597) Use ResourceGuard to make sure snapshot quit before ForSt dispose
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37591) Add Some PruneEmptyRules
Jacky Lau (Jira)
[jira] [Created] (FLINK-37596) Close metric groups for finished splits
Efrat Levitan (Jira)
[RESULT][VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
[jira] [Created] (FLINK-37595) Add Join remove rules.
Jacky Lau (Jira)
[jira] [Created] (FLINK-37594) Remove targetColumns in DynamicTableSink/Sink/SinkRuntimeProviderContext
xiangyu feng (Jira)
[jira] [Created] (FLINK-37593) Add some Reduce Expression Rules
Jacky Lau (Jira)
[jira] [Created] (FLINK-37592) Update docs about SupportsTargetColumnWriting ability
xiangyu feng (Jira)
[jira] [Created] (FLINK-37590) Update the code of Python modules to adapt to Flink 2.0's pyFlink
Yanquan Lv (Jira)
[jira] [Created] (FLINK-37588) Flink Kubernetes Operator Parameter `jm-deployment.shutdown-ttl` does not take effect
yuanfenghu (Jira)
[jira] [Created] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform
Yanquan Lv (Jira)
[VOTE] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [VOTE] FLIP-512: Add meta information to SQL state connector
gongzhongqiang
Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
Re:Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Yuepeng Pan
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Andrei Kaigorodov
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Rui Fan
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Ferenc Csaky
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: Re: [VOTE] FLIP-512: Add meta information to SQL state connector
Lincoln Lee
Slack Invite
George Niece
[jira] [Created] (FLINK-37585) The data of the newly added table cannot be read
jeff-zou (Jira)
[jira] [Created] (FLINK-37583) Upgrade Kafka Client version to 4.0.0
Thomas Cooper (Jira)
[VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Ferenc Csaky
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Gyula Fóra
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Zakelly Lan
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Mate Czagany
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Xiqian YU
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Yanquan Lv
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Márton Balassi
Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1
Ferenc Csaky
[jira] [Created] (FLINK-37577) Wait compaction only when table set deletion-vectors.enabled to true in PaimonWriter
Yanquan Lv (Jira)
[jira] [Created] (FLINK-37582) Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-37581) Avoid duplicate calculation for total Flink memory
Jiaan Geng (Jira)
Pyflink improvements proposal
Hugo POLSINELLI
RE: Pyflink improvements proposal
Hugo POLSINELLI
[jira] [Created] (FLINK-37580) Add checkpoint restore metric in in Flink Web UI
yanpengshi (Jira)
[jira] [Created] (FLINK-37579) Avoid duplicate generate ResourceProfile
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37578) CDC Pipeline distributed schema evolution topology with bad internal state
yux (Jira)
Earlier messages
Later messages