dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
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
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
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
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
Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
[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
Re: [VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history
yuanfeng hu
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
Re: [DISCUSS] Planning Flink 2.1
Ron Liu
Re: [DISCUSS] Planning Flink 2.1
Leonard Xu
[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
Shengkai Fang
Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Lincoln Lee
Re: [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
Shengkai Fang
Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs
Shengkai Fang
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
Re: [DISCUSS] FLIP-518: Introduce a community review process
Robert Metzger
RE: [DISCUSS] FLIP-518: Introduce a community review process
David Radley
Re: [DISCUSS] FLIP-518: Introduce a community review process
Robert Metzger
Re: [DISCUSS] FLIP-518: Introduce a community review process
Sebastien Pereira
Re: [DISCUSS] FLIP-518: Introduce a community review process
David Radley
Re: [DISCUSS] FLIP-518: Introduce a community review process
Robert Metzger
[VOTE] FLIP-518: Introduce a community review process
David Radley
Re: [VOTE] FLIP-518: Introduce a community review process
Robert Metzger
[VOTE] FLIP-518: Introduce a community review process
David Radley
FW: [VOTE] FLIP-518: Introduce a community review process
David Radley
Re: [VOTE] FLIP-518: Introduce a community review process
Ferenc Csaky
[VOTE] FLIP-518: Introduce a community review process
Hong Liang
Re: [VOTE] FLIP-518: Introduce a community review process
Yuepeng Pan
Re: [VOTE] FLIP-518: Introduce a community review process
Robert Metzger
[DISCUSS] FLIP-518: Introduce a community review process
David Radley
FW: [DISCUSS] FLIP-518: Introduce a community review process
David Radley
FW: [DISCUSS] FLIP-518: Introduce a community review process
David Radley
[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
Earlier messages
Later messages