dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
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
[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)
[jira] [Created] (FLINK-37576) Batch job failed when submit JobGraph contains broadcast edge
Weijie Guo (Jira)
[jira] [Created] (FLINK-37575) Simplify the code for creating netty shuffle environment.
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37574) Add UDTF support in YAML pipeline transform expressions
yux (Jira)
[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)
Process table function scan operation in batch mode is not supported
Gabor Somogyi
Earlier messages
Later messages