dev
Thread
Date
Earlier messages
Messages by Thread
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 Committer - Sergey Nuyanzin
Andriy Redko
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
gyula . fora
Re: [VOTE] FLIP-515: Dynamic Kafka Sink
Gabor Somogyi
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
[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)
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
Ferenc Csaky
Re: [EXTERNAL] Re: Executing PyFlink Cluster
Gabor Somogyi
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
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
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
xiangyu feng
[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
[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: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
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
[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
Re: Process table function scan operation in batch mode is not supported
Shengkai Fang
Re: Process table function scan operation in batch mode is not supported
Gyula Fóra
Re: Process table function scan operation in batch mode is not supported
Timo Walther
Re: Process table function scan operation in batch mode is not supported
Gyula Fóra
Re: Process table function scan operation in batch mode is not supported
Gabor Somogyi
Re: Process table function scan operation in batch mode is not supported
Shengkai Fang
[jira] [Created] (FLINK-37573) Deprecate Java 8 in Kafka
Arvid Heise (Jira)
[jira] [Created] (FLINK-37572) Shuffle Event by bucket and tableid to avoid data skew
Yanquan Lv (Jira)
[jira] [Created] (FLINK-37571) Last state upgrade mode broken for Flink 2.0
Gyula Fora (Jira)
[jira] [Created] (FLINK-37570) NullPointerException thrown for split-level watermarks
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-37569) Add userKeySerializer in RegisteredKeyValueStateBackendMetaInfo V2
Yue Ma (Jira)
[jira] [Created] (FLINK-37568) Improve the method flatten for class GlobalConfiguration
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism
Alan Zhang (Jira)
[VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Efrat Levitan
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Roman Khachatryan
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Leonard Xu
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Yuepeng Pan
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Martijn Visser
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Gyula Fóra
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Piotr Nowojski
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Aleksandr Savonin
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Ahmed Hamdy
[jira] [Created] (FLINK-37566) table.exclude was invalid in binlog reading phase when scan.binlog.newly-added-table.enabled
Yanquan Lv (Jira)
[VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
[jira] [Created] (FLINK-37565) Connector python CI failing for JDK 8
Hong Liang Teoh (Jira)
[RESULT] [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)
Gyula Fóra
[DISCUSS] FLIP-XXX: Checkpoint supports the Operator to customize asynchronous operation
jufang he
Re: [DISCUSS] FLIP-XXX: Checkpoint supports the Operator to customize asynchronous operation
Zakelly Lan
[jira] [Created] (FLINK-37564) Rework job error fetching to use Exception history instead of JobResults
Gyula Fora (Jira)
[jira] [Created] (FLINK-37561) Report system events
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-37562) Do not check all JM replicas in observer
Gyula Fora (Jira)
[jira] [Created] (FLINK-37563) Add additional metrics for DDB connector
Abhi Gupta (Jira)
[jira] [Created] (FLINK-37560) Document events reporting
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-37559) Produce warn log whenever CommitterOperator#snapshotState called
Chanhyeong Cho (Jira)
[jira] [Created] (FLINK-37518) Optimize number of files created by flink history server
Biao Geng (Jira)
[jira] [Created] (FLINK-37558) Check right variable on MetricRegistryImpl#addSpan
Chahyeong Cho (Jira)
[jira] [Created] (FLINK-37556) OpenTelemetry reporter does not package all required classes
Mate Czagany (Jira)
[VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Wei Zhong
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Feng Jin
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
[jira] [Created] (FLINK-37555) Postgres cdc supports starting from a specified offset or confirmed lsn
ouyangwulin (Jira)
[jira] [Created] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend
Yue Ma (Jira)
[jira] [Created] (FLINK-37553) Make ForStKeyedStateBackend consider namespaceSerializer compatibility when restoring state
Yue Ma (Jira)
[jira] [Created] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend.
Yue Ma (Jira)
[jira] [Created] (FLINK-37551) Improve the state compatibility of ForStKeyeStateBackend and ForStSyncKeyeStateBackend
Yue Ma (Jira)
[jira] [Created] (FLINK-37550) Add 2.0 to PreviousDocs list
Weijie Guo (Jira)
[jira] [Created] (FLINK-37549) Some scala and markdown syntax errors in tableApi page
cuiyanxiang (Jira)
[jira] [Created] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API
Yash Anand (Jira)
[jira] [Created] (FLINK-37537) Duplicate key when job failover in SchemaOperator
linqigeng (Jira)
[jira] [Created] (FLINK-37547) Add initial document for PTFs
Timo Walther (Jira)
[jira] [Created] (FLINK-37546) KryoSerializer breaks without Twitter Chill library
Maximilian Michels (Jira)
[jira] [Created] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Created] (FLINK-37544) Replace Timer with single thread scheduled executor for BlobServer
Jiaan Geng (Jira)
[DISCUSS] Planning Flink 2.1
Ron Liu
Re: [DISCUSS] Planning Flink 2.1
Jark Wu
RE: [DISCUSS] Planning Flink 2.1
David Radley
Re: [DISCUSS] Planning Flink 2.1
Xintong Song
Re: [DISCUSS] Planning Flink 2.1
Ron Liu
[jira] [Created] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context
xiangyu feng (Jira)
[ANNOUNCE] Apache Flink 2.0.0 released
Xintong Song
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Zakelly Lan
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Luke Chen
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Leonard Xu
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Yuan Mei
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Jingsong Li
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Jark Wu
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Neelesh Salian
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Xuannan Su
Re: [ANNOUNCE] Apache Flink 2.0.0 released
Yuepeng Pan
[jira] [Created] (FLINK-37543) Support sink reuse in batch mode
xiangyu feng (Jira)
[jira] [Created] (FLINK-37542) Support sink reuse in streaming mode
xiangyu feng (Jira)
[jira] [Created] (FLINK-37540) Introduce SupportsTargetColumnWriting sink ability
xiangyu feng (Jira)
[jira] [Created] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time
Yanquan Lv (Jira)
[jira] [Created] (FLINK-37536) Improve SQL gateway documentation
Ammu Parvathy (Jira)
[jira] [Created] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Timo Walther
Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Hao Li
Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Hao Li
RE: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Gustavo de Morais
RE: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Gustavo de Morais
Submitting multiple DELETE statements in Flink SQL
Kirill Lyashko
[DISCUSS] FLIP-518: Introduce a community review process
David Radley
Re: [DISCUSS] FLIP-518: Introduce a community review process
Doğuşcan Namal
[RESULT] [VOTE] FLIP-507: Add Model DDL methods in TABLE API
Yash Anand
[jira] [Created] (FLINK-37533) Reduce Stale PR Action timeouts
Thomas Cooper (Jira)
CHI: Add liiniting checks to all PRs
Tom Cooper
Re: CHI: Add liiniting checks to all PRs
Arvid Heise
Re: CHI: Add liiniting checks to all PRs
Ferenc Csaky
Re: CHI: Add liiniting checks to all PRs
Neelesh Salian
Re: CHI: Add liiniting checks to all PRs
Tom Cooper
2025/03/20 CHI Western time zone workgroup meeting minutes
David Radley
[jira] [Created] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure
Jun He (Jira)
[DISCUSS] Release externalized Kudu connector
Ferenc Csaky
Re: [DISCUSS] Release externalized Kudu connector
Márton Balassi
Re: [DISCUSS] Release externalized Kudu connector
Attila Kreiner
Re: [DISCUSS] Release externalized Kudu connector
Mate Czagany
Re: [DISCUSS] Release externalized Kudu connector
Ferenc Csaky
Re: [DISCUSS] Release externalized Kudu connector
Ferenc Csaky
[jira] [Created] (FLINK-37529) Add flink-cdc-commo to the package to all the incremental source framework
Hongshun Wang (Jira)
[jira] [Created] (FLINK-37530) Upgrade savepoints are not added to deprecated savepointinfo
Gyula Fora (Jira)
[jira] [Created] (FLINK-37522) Add description for the config about file system connection limit
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37527) Add `KuduSource` documentation
Ferenc Csaky (Jira)
[jira] [Created] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving
Maximilian Michels (Jira)
[jira] [Created] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37523) e2e: Test stream python udf sql job fails
Fabian Paul (Jira)
[RESULT] [VOTE] FLIP-513: Split-level watermark metrics
Efrat Levitan
[RESULT] [VOTE] FLIP-509: Pluggable Batching For Async Sink
Poorvank Bhatia
[jira] [Created] (FLINK-37521) Two input datastream operators with async state
Yanfei Lei (Jira)
[jira] [Created] (FLINK-37520) One input datastream operator with async state
Yanfei Lei (Jira)
[jira] [Created] (FLINK-37519) Add clearer logs when fail to write to YAML DataSink.
Yanquan Lv (Jira)
Earlier messages