dev
Thread
Date
Later messages
Messages by Thread
Re: [jira] [Created] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint
Ammu P
[DISCUSS] FLINK-36817 Feedback
Levani Kokhreidze
Re: [DISCUSS] FLINK-36817 Feedback
Levani Kokhreidze
[jira] [Created] (FLINK-36817) Give users ability to provide their own KafkaConsumer when using flink-connector-kafka
Levani Kokhreidze (Jira)
[jira] [Created] (FLINK-36816) Support source parallelism setting for JDBC connector
Jira
[jira] [Created] (FLINK-36815) series bugs of DSv2
xuhuang (Jira)
[jira] [Created] (FLINK-36814) Flink CDC Support Mutil Datasource
melin (Jira)
[jira] [Created] (FLINK-36813) MySQLCDC supports synchronization of specified fields
Di Wu (Jira)
[jira] [Created] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type.
ouyangwulin (Jira)
[jira] [Created] (FLINK-36811) MySQL CDC
Xuannan Su (Jira)
Upsert to Kafka with flink SQL
Emil Hjelle (ekstern)
Re: Upsert to Kafka with flink SQL
Emil Hjelle (ekstern)
[jira] [Created] (FLINK-36810) Reflective access warning not addressed causing Flink failing to process job creation
Yusu Gao (Jira)
[jira] [Created] (FLINK-36809) Add ifNotExists param to createTable
Gustavo de Morais (Jira)
[jira] [Created] (FLINK-36808) UNION ALL after lookup join produces unexpected results
Qingsheng Ren (Jira)
Re: Blue/Green Deployments support for Flink
Danny Cranmer
Re: Blue/Green Deployments support for Flink
Sergio Chong Loo
Re: Blue/Green Deployments support for Flink
Sergio Chong Loo
Re: Blue/Green Deployments support for Flink
Maximilian Michels
RE: Blue/Green Deployments support for Flink
David Radley
Re: Blue/Green Deployments support for Flink
Alexander Fedulov
Re: Blue/Green Deployments support for Flink
Sergio Chong Loo
Re: Blue/Green Deployments support for Flink
Alex Nitavsky
Re: Blue/Green Deployments support for Flink
Alex Nitavsky
Re: Blue/Green Deployments support for Flink
Yang LI
Re: Blue/Green Deployments support for Flink
Alexander Fedulov
Re: Blue/Green Deployments support for Flink
Alex Nitavsky
Re: Blue/Green Deployments support for Flink
Sergio Chong Loo
Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD
Lajith Koova
RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD
David Radley
[jira] [Created] (FLINK-36807) Add coverage for pre-writer and pre-commit topologies for SinkV2
Arvid Heise (Jira)
[jira] [Created] (FLINK-36806) Support for synchronization between timestamp fields with and without time zones to avoid time offsets
zjjiang (Jira)
[ANNOUNCE] Apache Flink CDC 3.2.1 released
Hang Ruan
[jira] [Created] (FLINK-36805) Add support for using encrypted passwords in pipeline definitions
zjjiang (Jira)
[jira] [Created] (FLINK-36804) When the same number of characters in Chinese names exists, initiate error reporting.
hzk (Jira)
[RESULT][VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Hang Ruan
[jira] [Created] (FLINK-36803) Use fixed format for splitId in all connectors
Ruan Hang (Jira)
[ANNOUNCE] Apache flink-connector-kafka 3.4.0 released
Arvid Heise
[jira] [Created] (FLINK-36802) Add CompiledPlan annotations to BatchExecSortMergeJoin
Jim Hughes (Jira)
[jira] [Created] (FLINK-36801) Update CI image to Ubuntu 22.04
Mehdi (Jira)
[jira] [Created] (FLINK-36800) Upgrade hadoop-aws to avoid CVE-2019-14887
Fabian Paul (Jira)
[jira] [Created] (FLINK-36799) iceberg sink支持pipeline配置方式的connector
Jira
[jira] [Created] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase
Yanquan Lv (Jira)
[jira] [Created] (FLINK-36797) hudi sink支持pipeline配置方式的connector
Jira
[jira] [Created] (FLINK-36796) oracle cdc支持pipeline配置方式的connector
Jira
[jira] [Created] (FLINK-36795) postgres cdc支持pipeline配置方式的connector
Jira
[jira] [Created] (FLINK-36794) mysql cdc和postgres cdc对于分表分库场景的支持
Jira
[jira] [Created] (FLINK-36793) oracle cdc的增量快照的块分割器逻辑有问题导致分割的片过大的问题
Jira
[jira] [Created] (FLINK-36792) FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed
Jacky Lau (Jira)
[jira] [Created] (FLINK-36791) FlinkPruneEmptyRules can be removed because high version calcite has fixed
Jacky Lau (Jira)
[jira] [Created] (FLINK-36790) Flink CDC to Paimon: DeletionVectorsMaintainer CME problem
Rascal Wu (Jira)
[RESULT][VOTE] flink-connector-kafka 3.4.0, release candidate #1
Arvid Heise
[jira] [Created] (FLINK-36789) Update FunctionHint and ArgumentHint with StaticArguments
Timo Walther (Jira)
[jira] [Created] (FLINK-36788) Add coverage for GlobalCommitter for SinkV2
Arvid Heise (Jira)
[jira] [Created] (FLINK-36787) Flink SQL mode kafka join jdbc Dimension Table Yarn node OOM
zhengyuan (Jira)
[jira] [Created] (FLINK-36786) Memory leak in SplitFetcherManager#close
Zhen Wang (Jira)
[jira] [Created] (FLINK-36785) Improve Starrocks unsupported field error return value
hunter (Jira)
[jira] [Created] (FLINK-36784) Support to add metadata columns for data in the meta fields of DataChangeEvent at transform
Ruan Hang (Jira)
[jira] [Created] (FLINK-36783) CTAS from VALUES throws ValidatioonException
Yunfeng Zhou (Jira)
[jira] [Created] (FLINK-36782) Incorrect comment syntax
altenchen (Jira)
[jira] [Created] (FLINK-36781) Flink SQL REPL Remote Gateway lag
k walton (Jira)
[RESULT][VOTE] Release flink-connector-hbase v4.0.0, release candidate #1
Ferenc Csaky
[jira] [Created] (FLINK-36780) Kafka source disable partition discovery unexpectedly
Mingliang Liu (Jira)
[Discussion] Session Clusters Support Heterogeneous Task Manager Images
Ryan van Huuksloot
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Shengkai Fang
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Ryan van Huuksloot
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Shengkai Fang
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Ryan van Huuksloot
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Shengkai Fang
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Dian Fu
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Ryan van Huuksloot
[DISCUSS] Flink 1.20.1 release
Alexander Fedulov
Re: [DISCUSS] Flink 1.20.1 release
Rui Fan
Re: [DISCUSS] Flink 1.20.1 release
Ferenc Csaky
Re: [DISCUSS] Flink 1.20.1 release
ConradJam
Re: [DISCUSS] Flink 1.20.1 release
weijie guo
Re: [DISCUSS] Flink 1.20.1 release
Zakelly Lan
Re: [DISCUSS] Flink 1.20.1 release
Roman Khachatryan
Re: [DISCUSS] Flink 1.20.1 release
Tom Cooper
Re: [DISCUSS] Flink 1.20.1 release
Yuepeng Pan
RE: Re: [DISCUSS] Flink 1.20.1 release
Ammu P
RE: Re: [DISCUSS] Flink 1.20.1 release
David Radley
Re: Re: [DISCUSS] Flink 1.20.1 release
ConradJam
Re: Re: [DISCUSS] Flink 1.20.1 release
Alexander Fedulov
Re: [DISCUSS] Flink 1.20.1 release
Ammu P
RE: [DISCUSS] Flink 1.20.1 release
Piotr Przybylski
Re: [DISCUSS] Flink 1.20.1 release
Alexander Fedulov
Re: [DISCUSS] Flink 1.20.1 release
Piotr Przybylski
[DISCUSS] Flink 1.19.2 release
Alexander Fedulov
Re: [DISCUSS] Flink 1.19.2 release
Rui Fan
Re: [DISCUSS] Flink 1.19.2 release
Ferenc Csaky
[jira] [Created] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time
Roman Boyko (Jira)
[jira] [Created] (FLINK-36778) The default implementation
shaohui hong (Jira)
[DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
yuanfeng hu
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Matthias Pohl
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Rui Fan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Rui Fan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Eric Xiao
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Peter Huang
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan
[jira] [Created] (FLINK-36777) The implementation of getting chunk key column in ChunkUtils.java is weired
shaohui hong (Jira)
[jira] [Created] (FLINK-36776) OracleIncrementalSource does not support partitioned table
shaohui hong (Jira)
[jira] [Created] (FLINK-36775) fetchSize set in OracleIncrementalSource is not working
shaohui hong (Jira)
[jira] [Created] (FLINK-36774) SQL gateway should support executing multiple SQL statements once
tim yu (Jira)
[jira] [Created] (FLINK-36773) Introduce new Group Agg Operator with Async State API
xuyang (Jira)
[jira] [Created] (FLINK-36772) Fix Preconditions errorMessageTemplate is error
Xin Gong (Jira)
[jira] [Created] (FLINK-36771) Flink cdc UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED]
Xin Gong (Jira)
Plans for JDBC connector for 1.20?
David Radley
FW: Plans for JDBC connector for 1.20?
David Radley
Re: Plans for JDBC connector for 1.20?
Yanquan Lv
RE: Plans for JDBC connector for 1.20?
David Radley
Re: Plans for JDBC connector for 1.20?
Hang Ruan
Re: Plans for JDBC connector for 1.20?
Peter Huang
RE: Plans for JDBC connector for 1.20?
David Radley
Re: Plans for JDBC connector for 1.20?
Hang Ruan
Re: Plans for JDBC connector for 1.20?
Xingcan Cui
RE: Plans for JDBC connector for 1.20?
David Radley
Re: Plans for JDBC connector for 1.20?
Yanquan Lv
Re: Plans for JDBC connector for 1.20?
Hang Ruan
RE: Re: Plans for JDBC connector for 1.20?
Jérôme Gagnon
[jira] [Created] (FLINK-36770) Support Request Timeout for AWS sinks
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-36769) Suport fury Serializer for pyflink
xingyuan cheng (Jira)
[jira] [Created] (FLINK-36768) Empty Checkpoint Directory created when older checkpoint fails due to timeout and the checkpoint interval is same
Eaugene Thomas (Jira)
回复: [jira] [Created] (FLINK-36768) Empty Checkpoint Directory created when older checkpoint fails due to timeout and the checkpoint interval is same
Xia Rui
[jira] [Created] (FLINK-36766) Use pyflink to create remote env
William Que (Jira)
[jira] [Created] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0
Siddharth R (Jira)
[jira] [Created] (FLINK-36765) How to Handle Multi-Type Maps in Avro Schema with Flink Table API?
Maneendra (Jira)
[VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Hang Ruan
Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Hang Ruan
Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Yanquan Lv
Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Leonard Xu
Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Lincoln Lee
Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1
Xingbo Huang
Re: Planned release dates for 1.19.2 and 1.20.1
Prasanna kumar
Re: Planned release dates for 1.19.2 and 1.20.1
Robert Metzger
[jira] [Created] (FLINK-36764) Add checkpoint type to checkpoint trace
Piotr Nowojski (Jira)
Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1
Leonard Xu
Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1
Martijn Visser
Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1
Ahmed Hamdy
Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1
Danny Cranmer
Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1
Arvid Heise
[jira] [Created] (FLINK-36761) Add document about how to deploy script with SQL Client and SQL Gateway
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources
yux (Jira)
[jira] [Created] (FLINK-36756) Bump up the sql-gateway rest api version
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36757) Introduce splitter to split scripts
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36760) Support to deploy script via sql client
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36762) Add E2ECase to run sql client in application mode
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36759) Intrdouce REST API to deploy script
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36758) Introduce driver to load the application in application mode
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36755) Relax the limit about the pipeline.jar must have one in application mode
Shengkai Fang (Jira)
[jira] [Created] (FLINK-36754) When projection is empty or null, it is treated as an asterisk
MOBIN (Jira)
[jira] [Created] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint
Rui Fan (Jira)
[jira] [Created] (FLINK-36752) Emit state related metrics when checkpoints are disabled
Sai Sharath Dandi (Jira)
Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1
Gyula Fóra
Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1
Arvid Heise
Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1
Ferenc Csaky
[jira] [Created] (FLINK-36751) PausableRelativeClock does not pause when the source only has one split
haishui (Jira)
[jira] [Created] (FLINK-36750) Paimon connector would reuse sequence number when schema evolution happened
Yanquan Lv (Jira)
[DISCUSS] Release Flink CDC version 3.2.1
Hang Ruan
Re: [DISCUSS] Release Flink CDC version 3.2.1
Leonard Xu
[jira] [Created] (FLINK-36749) Implement rescaling for ForStKeyedStateBackend
Yanfei Lei (Jira)
FW: RE: Flink technical debt.
David Radley
Re: FW: RE: Flink technical debt.
Jim Hughes
RE: FW: RE: Flink technical debt.
David Radley
FW: Re: Flink technical debt.
David Radley
Re: FW: Re: Flink technical debt.
Sergey Nuyanzin
RE: FW: Re: Flink technical debt.
David Radley
FW: Re: Flink technical debt.
David Radley
FW: Re: Flink technical debt. Chi meeting
David Radley
FW: FW: Re: Flink technical debt. Chi meeting
David Radley
Flink technical debt. Chi meeting
David Radley
Join slack
Ecaterina-Sonia Lazarescu
[jira] [Created] (FLINK-36748) Web UI can stop job with savepoint and upload yaml file
vertern (Jira)
[jira] [Created] (FLINK-36747) History server can manage archived jobs
vertern (Jira)
Re: Dynamic Iceberg Sink
ConradJam
Re: Dynamic Iceberg Sink
Anil Dasari
Re: Dynamic Iceberg Sink
Maximilian Michels
Re: Dynamic Iceberg Sink
Anil Dasari
Re: Dynamic Iceberg Sink
Anil Dasari
Re: Dynamic Iceberg Sink
Maximilian Michels
[jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS)
Mehdi (Jira)
RE: [jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS)
Mehdi Deboub
[jira] [Created] (FLINK-36746) Found deadlock in SerializedThrowable
xiongraorao (Jira)
[jira] [Created] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs
Andrei Kaigorodov (Jira)
[jira] [Created] (FLINK-36744) Document operator's FlinkVersion compatibility
Dylan Meissner (Jira)
[jira] [Created] (FLINK-36743) Rescale from unaligend checkpoint failed
Feifan Wang (Jira)
[jira] [Created] (FLINK-36742) Filter unacked split for no capture tables when task restore from state
Xin Gong (Jira)
[jira] [Created] (FLINK-36741) The precision of Decimal has been lost when use FlinkCDC transform
Wenkai Qi (Jira)
[jira] [Created] (FLINK-36740) Dependencies update to address vulnerabilities
Mehdi (Jira)
Re: Flink V1 to V2 state migration
Xu Huang
RE: Flink V1 to V2 state migration
David Radley
[jira] [Created] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21
Jiabao Sun (Jira)
[jira] [Created] (FLINK-36737) flink-shaded-hadoop-2-uber contains the common io version incompatible with the flink client
melin (Jira)
Later messages