dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Created] (FLINK-37432) Add release note for release 2.0
Weijie Guo (Jira)
upgrade DebeziumJsonDeserializationSchema
Semen Pavelko
Re: upgrade DebeziumJsonDeserializationSchema
David Radley
[jira] [Created] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error
zlzhang0122 (Jira)
[jira] [Created] (FLINK-37430) Operator hides the actual error on deployment issues
Gyula Fora (Jira)
[jira] [Created] (FLINK-37427) incorrect NPE message in StandaloneHaServices constructor
LuJiang (Jira)
[ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released
Gyula Fóra
Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released
Gyula Fóra
[jira] [Created] (FLINK-37426) FLIP-481: Introduce Event Reporting
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-37425) Sanity check before ForSt cache created
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37424) Using JDK17 for the binary convenience release
Weijie Guo (Jira)
[jira] [Created] (FLINK-37423) Add support for PTFs in Table API
Timo Walther (Jira)
[SUMMARY] Flink 2.0 Release Sync 03/05/2025
Xintong Song
Question on usage of SQL Gateway with a remote Flink cluster
Ammu P
Re: Question on usage of SQL Gateway with a remote Flink cluster
Shengkai Fang
Re: Question on usage of SQL Gateway with a remote Flink cluster
Ammu P
Re: Question on usage of SQL Gateway with a remote Flink cluster
Shengkai Fang
Re: Question on usage of SQL Gateway with a remote Flink cluster
Ammu P
Re: Question on usage of SQL Gateway with a remote Flink cluster
Shengkai Fang
[jira] [Created] (FLINK-37422) Typo in streaming analytics zh document
ronghangye (Jira)
[jira] [Created] (FLINK-37421) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the deployment
Julian (Jira)
[jira] [Created] (FLINK-37420) AbstractAggregatingState add may return wrong result
Yue Ma (Jira)
[jira] [Created] (FLINK-37419) ForStMapState serializeValue may get wrong result
Yue Ma (Jira)
[jira] [Created] (FLINK-37418) caugth array out of index exception while using RowData.getArray method
Spongebob (Jira)
[jira] [Created] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery
Hong Liang Teoh (Jira)
[jira] [Created] (FLINK-37416) DDB Streams connector flink state inconsistency issue
Abhi Gupta (Jira)
[KINDLY REMINDER] Flink 2.0 Release Sync 03/05/2025
Xintong Song
[jira] [Created] (FLINK-37415) [Release-2.0] Prepare RC1 release
Xintong Song (Jira)
[jira] [Created] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
[jira] [Created] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Piotr Nowojski (Jira)
[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Gyula Fóra
[jira] [Created] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned
Matthias Pohl (Jira)
[jira] [Created] (FLINK-37411) Introduce the rollback mechanism for Autoscaler
Rui Fan (Jira)
[DISCUSS] Split-level Watermark Metrics
אפרת לויטן
Re: [DISCUSS] Split-level Watermark Metrics
Piotr Nowojski
Re: [DISCUSS] Split-level Watermark Metrics
Efrat Levitan
[jira] [Created] (FLINK-37410) Split-level Watermark Metrics
Efrat Levitan (Jira)
[jira] [Created] (FLINK-37409) Catch throwable in BinlogSplitReader to exit reading binlog when error occurs
Xiao Huang (Jira)
Flink vs beam-flink-runner benchmark
Taher Koitawala
Re: Flink vs beam-flink-runner benchmark
Taher Koitawala
Re: Flink vs beam-flink-runner benchmark
XQ Hu
[jira] [Created] (FLINK-37408) Update all docker-compose references to docker compose in documentation
Nil Madhab (Jira)
[DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Leonard Xu
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gyula Fóra
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Lincoln Lee
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Shengkai Fang
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Zakelly Lan
Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
[jira] [Created] (FLINK-37407) Add meta information to SQL state connector
Gabor Somogyi (Jira)
Minutes of the 2025/02/27 CHI Eastern time zone workgroup meeting
David Radley
[DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Hongshun Wang
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
RE: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
David Radley
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Hongshun Wang
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Hongshun Wang
[jira] [Created] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD
Gyula Fora (Jira)
[jira] [Created] (FLINK-37405) Perform upstream YAML config validation for Flink 2.x
Gyula Fora (Jira)
[jira] [Created] (FLINK-37404) Reenable Migration Tests for Filnk 2.x
Kurt Ostfeld (Jira)
[jira] [Created] (FLINK-37403) Support retractions/updates for IntervalJoin operator
Bonnie Varghese (Jira)
[jira] [Created] (FLINK-37402) SQL testing sources produce incorrect watermarks
Timo Walther (Jira)
[jira] [Created] (FLINK-37401) Add Job ID to logging context of slotmanager classes
Aleksandr Savonin (Jira)
[jira] [Created] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-37398) State processor API blows up with cryptic error when changelog used
Gabor Somogyi (Jira)
[jira] [Created] (FLINK-37397) Python wheel builds broken in nightly
Mika Naylor (Jira)
[jira] [Created] (FLINK-37396) Kafka connector python test fail
Hongshun Wang (Jira)
[jira] [Created] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered
zexin gong (Jira)
[RESULT][VOTE] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
[jira] [Created] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector
Ferenc Csaky (Jira)
[jira] [Created] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion
Rafael Zimmermann (Jira)
[jira] [Created] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state
junzhong qin (Jira)
[jira] [Created] (FLINK-37391) Change watchNamespace config in operator is not respected while running
Fabian Paul (Jira)
[jira] [Created] (FLINK-37388) [BUG] Field names must be unique.
zexin gong (Jira)
[jira] [Created] (FLINK-37390) Push filter into ChangelogNormalize
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-37389) Add "flink-sql-connector-kudu" module
Ferenc Csaky (Jira)
[SUMMARY] Flink 2.0 Release Sync 02/26/2025
Xintong Song
[jira] [Created] (FLINK-37387) License check behaves differently for different jdk versions
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover
Yanquan Lv (Jira)
Kubernetes operator questions
santhosh venkat
[jira] [Created] (FLINK-37385) Add support for smile format in flink main repo
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios
Lei Yang (Jira)
[jira] [Created] (FLINK-37383) ThrottleIterator from examples/utils does not properly throttle on next window after throttle is applied
Rafael Zimmermann (Jira)
[jira] [Created] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold
xingbe (Jira)
[VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Gyula Fóra
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Tom Cooper
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Gyula Fóra
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Rui Fan
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Maximilian Michels
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Gyula Fóra
[jira] [Created] (FLINK-37381) Typo in Join document
cnsky1103 (Jira)
[ANNOUNCE] Apache Flink-shaded 20.0 released
Sergey Nuyanzin
[KINDLY REMINDER] Flink 2.0 Release Sync 02/25/2025
Xintong Song
[jira] [Created] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector
Hongshun Wang (Jira)
[jira] [Created] (FLINK-37379) Lack of state cache load for ForSt after recovery
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues
slankka (Jira)
[jira] [Created] (FLINK-37377) Sync guava with guava in flink-shaded
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-37376) Bump flink-shaded to 20.0
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-37375) Checkpoint supports the Operator to customize asynchronous snapshot state
Jufang He (Jira)
FLIP-510: Drop ChangelogNormalize for operations which don't need it
Dawid Wysakowicz
Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Sergey Nuyanzin
Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Martijn Visser
Re:Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Xuyang
Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Dawid Wysakowicz
Re:Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Xuyang
Re: Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Dawid Wysakowicz
Re:Re: Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Xuyang
Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Timo Walther
Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Leonard Xu
Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it
Dawid Wysakowicz
[jira] [Created] (FLINK-37374) Support JSON built-in function for JSON_ARRAY
Gustavo de Morais (Jira)
[jira] [Created] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-37372) Savepoint error can cause operator to hang
Gyula Fora (Jira)
Integrating LLMs into apache flink pipelines
Ganesh
Re: Integrating LLMs into apache flink pipelines
Shengkai Fang
[VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
xiangyu feng
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
Zhanghao Chen
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
weijie guo
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
Leonard Xu
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
xiangyu feng
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
Lincoln Lee
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
Jingsong Li
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
Ron Liu
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
Rui Fan
Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
xiangyu feng
[jira] [Created] (FLINK-37371) Postgres CDC incremental source fails to handle upper-case table and column names
Sergei Morozov (Jira)
Request for PMC help to move forward with release of flink-shaded
Sergey Nuyanzin
Re: Request for PMC help to move forward with release of flink-shaded
Sergey Nuyanzin
[RESULT] [VOTE] Release flink-shaded 20.0, release candidate #1
Sergey Nuyanzin
This weeks Community Health Initiative (CHI) meeting
David Radley
[jira] [Created] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR
Luca Castelli (Jira)
[jira] [Created] (FLINK-37369) Flink CDC OceanBase Connector Throws Exception for Column DEFAULT VALUE CURRENT_TIMESTAMP
caixiaowei (Jira)
[jira] [Created] (FLINK-37368) MySQL Pipeline job failed to checkpoint after closing idle readers
yux (Jira)
[jira] [Created] (FLINK-37367) Properly inherit uploaded SST files after ForSt restore
Zakelly Lan (Jira)
[jira] [Created] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch
Shuyi Chen (Jira)
[DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Gyula Fóra
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Alexander Fedulov
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Rui Fan
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Gyula Fóra
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Timo Walther
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Gyula Fóra
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Nick Nezis
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Zhanghao Chen
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Martijn Visser
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Nick Nezis
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Jing Ge
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Gyula Fóra
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Xintong Song
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Gyula Fóra
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Kurt Ostfeld
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Kurt Ostfeld
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Xintong Song
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Zakelly Lan
Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0
Gyula Fóra
Re:回复:[ANNOUNCE] New Apache Flink Committer - Feng Jin
Xuyang
Re: 回复:[ANNOUNCE] New Apache Flink Committer - Feng Jin
Jacky Lau
Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin
Leonard Xu
[ANNOUNCE] New Apache Flink Committer - Feng Jin
Lincoln Lee
Re:[ANNOUNCE] New Apache Flink Committer - Feng Jin
Yuepeng Pan
Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin
Ron Liu
Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin
Shengkai Fang
Earlier messages
Later messages