dev
Thread
Date
Earlier messages
Messages by Thread
[jira] [Created] (FLINK-35448) Translate pod templates documentation into Chinese
Caican Cai (Jira)
[DISCUSS] Flink 1.19.1 release
Hong Liang
Re: [DISCUSS] Flink 1.19.1 release
Danny Cranmer
[jira] [Created] (FLINK-35447) Flink CDC Document document file had removed but website can access
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35445) Update Async Sink documentation for Timeout configuration
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore
LvYanquan (Jira)
[jira] [Created] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code
Weijie Guo (Jira)
[jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism
LvYanquan (Jira)
[jira] [Created] (FLINK-35441) Add CDC upgrade compatibility tests
yux (Jira)
[VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jane Chan
Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Lincoln Lee
Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
weijie guo
Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Leonard Xu
Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Rui Fan
[jira] [Created] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver
Zach (Jira)
[jira] [Created] (FLINK-35439) Python Support for AvroSchemaConverter
Greg Wills (Jira)
[jira] [Created] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35437) BlockStatementGrouper uses lots of memory
Dawid Wysakowicz (Jira)
[VOTE] FLIP-443: Interruptible watermark processing
Piotr Nowojski
Re: [VOTE] FLIP-443: Interruptible watermark processing
Zakelly Lan
Re: [VOTE] FLIP-443: Interruptible watermark processing
Yanfei Lei
Re: [VOTE] FLIP-443: Interruptible watermark processing
Rui Fan
Re: [VOTE] FLIP-443: Interruptible watermark processing
weijie guo
Re: [VOTE] FLIP-443: Interruptible watermark processing
Martijn Visser
[jira] [Created] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE
hk__lrzy (Jira)
[jira] [Created] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-35434) Support pass exception in StateExecutor to runtime
Feifan Wang (Jira)
[jira] [Created] (FLINK-35433) Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service
Pavel (Jira)
[jira] [Created] (FLINK-35432) Support catch modify-event for mysql-cdc
hk__lrzy (Jira)
[jira] [Created] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema
LvYanquan (Jira)
[jira] [Created] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
[jira] [Created] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE
Weijie Guo (Jira)
[DISCUSS] Flink CDC Upgrade Debezium version to 2.x
gongzhongqiang
Re: [DISCUSS] Flink CDC Upgrade Debezium version to 2.x
Leonard Xu
Re: [DISCUSS] Flink CDC Upgrade Debezium version to 2.x
Hang Ruan
[jira] [Created] (FLINK-35427) Support fail-on-unknown-field config in json format
huhuan (Jira)
[jira] [Created] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast
xingbe (Jira)
[jira] [Created] (FLINK-35425) Support convert Freshness to cron expression for full refresh mode
dalongliu (Jira)
[jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context
Mingliang Liu (Jira)
[RESULT][VOTE] FLIP-451: Introduce timeout configuration to AsyncSink
Ahmed Hamdy
[jira] [Created] (FLINK-35423) ARRAY_EXCEPT should support set semantics
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-35422) Flink dynamically adjusts operator-level resource usage without stopping the job
Jira
[jira] [Created] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout
hk__lrzy (Jira)
[jira] [Created] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-35419) scan.bounded.latest-offset makes queries never finish if the latest message is a EndTxn Kafka marker
Fabian Paul (Jira)
[jira] [Created] (FLINK-35418) EventTimeWindowCheckpointingITCase fails with an NPE
Ryan Skraba (Jira)
[SUMMARY] Flink 1.20 Release Sync 05/21/2024
weijie guo
Re: [SUMMARY] Flink 1.20 Release Sync 05/21/2024
Rui Fan
[jira] [Created] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
melin (Jira)
[jira] [Created] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile
Weijie Guo (Jira)
[jira] [Created] (FLINK-35415) CDC Fails to create sink with Flink 1.19
yux (Jira)
[jira] [Created] (FLINK-35414) Cancel jobs through rest api for last-state upgrades
Gyula Fora (Jira)
[jira] [Created] (FLINK-35413) VertexFinishedStateCheckerTest causes exit 239
Ryan Skraba (Jira)
[DISCUSS] The performance of serializerHeavyString starts regress since April 3
Rui Fan
Re: [DISCUSS] The performance of serializerHeavyString starts regress since April 3
Zakelly Lan
Re: [DISCUSS] The performance of serializerHeavyString starts regress since April 3
Rui Fan
Re: [DISCUSS] The performance of serializerHeavyString starts regress since April 3
weijie guo
Re: [DISCUSS] The performance of serializerHeavyString starts regress since April 3
Sam Barker
[DISCUSS] Flink upgrade compatibility page not updated for Flink 1.19
Aleksandr Pilipenko
Re: [DISCUSS] Flink upgrade compatibility page not updated for Flink 1.19
Lincoln Lee
[jira] [Created] (FLINK-35412) Batch execution of async state request callback
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
Xiao Huang (Jira)
[jira] [Created] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
Xiao Huang (Jira)
Re: [DISCUSS] Proposing an LTS Release for the 1.x Line
Alexander Fedulov
Re: [DISCUSS] Proposing an LTS Release for the 1.x Line
Xintong Song
Re: [DISCUSS] Proposing an LTS Release for the 1.x Line
Alexander Fedulov
RE: [DISCUSS] Proposing an LTS Release for the 1.x Line
David Radley
Re: [DISCUSS] Proposing an LTS Release for the 1.x Line
Martijn Visser
Re: [DISCUSS] Proposing an LTS Release for the 1.x Line
Alexander Fedulov
RE: [DISCUSS] Proposing an LTS Release for the 1.x Line
David Radley
[jira] [Created] (FLINK-35407) ensure orderly transactions during the full consumption stage of MySQL CDC
xiaotouming (Jira)
[jira] [Created] (FLINK-35406) Use inner serializer when casting RAW type to BINARY or STRING in cast rules
Zhenghua Gao (Jira)
[jira] [Created] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController
Yanfei Lei (Jira)
[RESULT][VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
Xuannan Su
[jira] [Created] (FLINK-35404) Report metrics of KafkaConsumer in new Kafka source
Harshit Mittal (Jira)
[jira] [Created] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Alan Sheinberg (Jira)
[jira] [Created] (FLINK-35402) [flink-operator][Deployment] add labels to metadata
Jira
[jira] [Created] (FLINK-35401) Add SQS Table API support
Ahmed Hamdy (Jira)
AppClassLoader leakage to MiniCluster
Jan Lukavský
[jira] [Created] (FLINK-35400) Rebuild FileMergingSnapshotManager in failover
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35399) Add documents for batch job master failure recovery
Zhu Zhu (Jira)
[jira] [Created] (FLINK-35398) SqlGatewayE2ECase failed to pull image
Weijie Guo (Jira)
[jira] [Created] (FLINK-35397) Translate Controller Flow documentation into Chinese
Caican Cai (Jira)
[jira] [Created] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order
Suxing Lee (Jira)
[jira] [Created] (FLINK-35395) Fix KeyedStateStore class annotation error
bradley (Jira)
[jira] [Created] (FLINK-35394) paimon pipeline support dynamic bucket
melin (Jira)
[jira] [Created] (FLINK-35393) Support flink kafka catalog
melin (Jira)
[RESULT][VOTE] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Alan Sheinberg
[RESULT][VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
[jira] [Created] (FLINK-35392) SQL Lookup Join on external database failing when using 'FOR SYSTEM_TIME AS OF' statement
Glauber M Dantas (Jira)
[jira] [Created] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0
LvYanquan (Jira)
[ANNOUNCE] Apache Flink CDC 3.1.0 released
Qingsheng Ren
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
Leonard Xu
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
Hang Ruan
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
ConradJam
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
Ahmed Hamdy
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
Yanquan Lv
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
gongzhongqiang
Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
Muhammet Orazov
Re: Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released
Jingsong Li
[jira] [Created] (FLINK-35390) Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version
Jira
[jira] [Created] (FLINK-35389) Implement List Async State API for ForStStateBackend
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory
Jira
[jira] [Created] (FLINK-35387) PG CDC source support heart beat
Hongshun Wang (Jira)
[jira] [Created] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable
Qingsheng Ren (Jira)
[jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19
Hongshun Wang (Jira)
[RESULT][VOTE] Apache Flink CDC Release 3.1.0, release candidate #3
Qingsheng Ren
[Discuss] expose TaskIOMetricGroup to custom Partitioner
Steven Wu
[jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner
Steven Zhen Wu (Jira)
[jira] [Created] (FLINK-35383) Update compatibility matrix to include 1.19 release
Aleksandr Pilipenko (Jira)
[jira] [Created] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE
Ryan Skraba (Jira)
[DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0
Ferenc Csaky
Re: [DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0
Xintong Song
[jira] [Created] (FLINK-35381) LocalRecoveryITCase failure on deleting directory
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35379) File merging manager is not properly notified about checkpoint
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc
Martijn Visser (Jira)
[jira] [Created] (FLINK-35377) debezium-json support soft deletion.
Tongkai Yin (Jira)
[jira] [Created] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed
Jira
[jira] [Created] (FLINK-35375) About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2
Jira
[jira] [Created] (FLINK-35374) Flink 1.14 kafka connector Demo Error
hongxu han (Jira)
[jira] [Created] (FLINK-35373) Beautify Flink CDC Paimon Sink web ui
JunboWang (Jira)
[jira] [Created] (FLINK-35372) flink-cdc from mysql to doris, gives an error Unsupported type:TIME(0) when mysql data type is TIME and synchronise table structure or data.
joeb (Jira)
[jira] [Created] (FLINK-35371) Allow the keystore and truststore type to configured for SSL
Ammar Master (Jira)
[jira] [Created] (FLINK-35370) Create a temp module to test backward compatibility
Jira
[VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1
Sergey Nuyanzin
Re: [VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1
Andrey Redko
Re: [VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1
Leonard Xu
Re: [VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1
Leonard Xu
[VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Sergey Nuyanzin
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Andrey Redko
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Leonard Xu
[DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Keith Lee
Re: [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Martijn Visser
Re: [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Keith Lee
Re: [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Martijn Visser
[jira] [Created] (FLINK-35369) Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Keith Lee (Jira)
[RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc
Joao Boto
Re: [RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc
Rui Fan
Re: [RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc
lorenzo . affetti
Re: [RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc
João Boto
[RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc
Joao Boto
[jira] [Created] (FLINK-35368) Reorganize table code
Jira
[jira] [Created] (FLINK-35367) Reorganize datastream sink and source
Jira
[jira] [Created] (FLINK-35366) Create all database modules
Jira
[jira] [Created] (FLINK-35365) Reorganize catalog and dialect code
Jira
[jira] [Created] (FLINK-35364) Create core module and move code
Jira
[jira] [Created] (FLINK-35362) Reorganization of flink-connector-jdbc
Jira
[jira] [Created] (FLINK-35363) Reorganization of flink-connector-jdbc
Jira
Confirmation on Lambda Support for UDFs in FlinkSQL / Table API
Tucker Harvey
Re:Confirmation on Lambda Support for UDFs in FlinkSQL / Table API
Xuyang
Re: Confirmation on Lambda Support for UDFs in FlinkSQL / Table API
Tucker Harvey
Re:Re: Confirmation on Lambda Support for UDFs in FlinkSQL / Table API
Xuyang
[jira] [Created] (FLINK-35361) Delete Flinkhistory files that failed to write to the local directory
dengxaing (Jira)
[DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jane Chan
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Xuannan Su
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jark Wu
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Yubin Li
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Lincoln Lee
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Benchao Li
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Ron Liu
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jane Chan
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Lincoln Lee
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jane Chan
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Leonard Xu
Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jane Chan
[jira] [Created] (FLINK-35360) [Feature] Submit Flink CDC pipeline job to yarn Application mode
Jira
[jira] [Created] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xuannan Su (Jira)
[VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
Xuannan Su
Re: [VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
Rui Fan
Re: [VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
weijie guo
Re: [VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
Xintong Song
Re: [VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
Xuannan Su
[jira] [Created] (FLINK-35358) Breaking change when loading artifacts
Rasmus Thygesen (Jira)
[DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline
Jerry
Re: [DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline
Leonard Xu
Re: [DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline
Yanquan Lv
Proposal to Add a JDBC Sink Plugin to Flink-CDC-Pipeline
Jerry
[jira] [Created] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document
Yang Zhou (Jira)
Community over Code EU 2024: The countdown has started!
Ryan Skraba
[jira] [Created] (FLINK-35356) Async reducing state
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35355) Async aggregating state
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35354) [discuss] Support host mapping in Flink tikv cdc
ouyangwulin (Jira)
[jira] [Created] (FLINK-35353) Translate "Profiler" page into Chinese
Juan Zifeng (Jira)
[jira] [Created] (FLINK-35352) Add -sae submit task to run for a period of time and automatically cancel
Jira
[jira] [Created] (FLINK-35351) Restore from unaligned checkpoint with custom partitioner fails.
Dmitriy Linevich (Jira)
[jira] [Created] (FLINK-35350) Add documentation for Kudu
Martijn Visser (Jira)
[VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
weijie guo
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Ferenc Csaky
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Rui Fan
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
gongzhongqiang
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Péter Váry
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Rodrigo Meneses
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
lorenzo . affetti
Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Muhammet Orazov
Earlier messages