Re: Configmaps not deleted Kubernetes HA

Hi Enrique, I think you are running into this problem FLINK-20695 [1]. In a nutshell, Flink only deletes the config maps when it shuts down at the moment. We want to change this with the next release. [1] https://issues.apache.org/jira/browse/FLINK-20695 Cheers, Till On Wed, May 5, 2021 at

Re: [Parquet support]

Hi, @Jingsong, I agree that adding a new feature (ParquetAvroInputFormat) to an old source API is a maintenance burden. But IMHO I think that while the new DataStream batch/streaming convergent API is not 100% functional we still need to maintain older sources and add missing features to

[jira] [Created] (FLINK-22587) Support aggregations in batch mode with DataStream API

Etienne Chauchot created FLINK-22587: Summary: Support aggregations in batch mode with DataStream API Key: FLINK-22587 URL: https://issues.apache.org/jira/browse/FLINK-22587 Project: Flink

Re: Flink SQL Cdc with schema changing

Sure, here's the use case that I want to solve. I want to stream CDC records that are inserted in kafka via debezium. We want to capture all events of Debezium, with an alter table add column, modify column, inserts, updates and deletes over an avro based file format which can then be queried. For

[jira] [Created] (FLINK-22586) Improve precision derivation for decimal arithmetics

Shuo Cheng created FLINK-22586: -- Summary: Improve precision derivation for decimal arithmetics Key: FLINK-22586 URL: https://issues.apache.org/jira/browse/FLINK-22586 Project: Flink Issue Type:

[jira] [Created] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

Yang Wang created FLINK-22585: - Summary: Add deprecated message when "-m yarn-cluster" is used Key: FLINK-22585 URL: https://issues.apache.org/jira/browse/FLINK-22585 Project: Flink Issue Type:

[jira] [Created] (FLINK-22584) Use protobuf-shaded in StateFun core.

Igal Shilman created FLINK-22584: Summary: Use protobuf-shaded in StateFun core. Key: FLINK-22584 URL: https://issues.apache.org/jira/browse/FLINK-22584 Project: Flink Issue Type:

Re: [ANNOUNCE] Apache Flink 1.13.0 released

Thanks to Dawid and Guowei for the great work! On Thu, May 6, 2021 at 4:48 PM Zhu Zhu wrote: > Thanks Dawid and Guowei for being the release managers! And thanks > everyone who has made this release possible! > > Thanks, > Zhu > > Yun Tang 于2021年5月6日周四 下午2:30写道： > >> Thanks for Dawid and

Re: [ANNOUNCE] Apache Flink 1.13.0 released

Thanks Dawid and Guowei for being the release managers! And thanks everyone who has made this release possible! Thanks, Zhu Yun Tang 于2021年5月6日周四 下午2:30写道： > Thanks for Dawid and Guowei's great work, and thanks for everyone involved > for this release. > > Best > Yun Tang >

Re: [DISCUSS] Backport FLIP-27 Kafka source connector fixes with API change to release-1.12.

Just to double check are the changes in the PR of Thomas even touching the API or would that be another PR? Or are the API changes contained to FLINK-20379? On Wed, May 5, 2021 at 8:29 PM Arvid Heise wrote: > After looking a bit more into it, I'm also +1. > > Let's merge it soonish. > > On Wed,

[jira] [Created] (FLINK-22583) Flink UI is not showing completed jobs once JM Leader is deleted

Bhagi created FLINK-22583: - Summary: Flink UI is not showing completed jobs once JM Leader is deleted Key: FLINK-22583 URL: https://issues.apache.org/jira/browse/FLINK-22583 Project: Flink Issue

[jira] [Created] (FLINK-22582) Scrollbar "jumps" when clicking on tabs for Scala and Python

Matthias created FLINK-22582: Summary: Scrollbar "jumps" when clicking on tabs for Scala and Python Key: FLINK-22582 URL: https://issues.apache.org/jira/browse/FLINK-22582 Project: Flink Issue

[jira] [Created] (FLINK-22581) Keyword 'CATALOG' is missing in sql client doc

YoungWoo Kim created FLINK-22581: Summary: Keyword 'CATALOG' is missing in sql client doc Key: FLINK-22581 URL: https://issues.apache.org/jira/browse/FLINK-22581 Project: Flink Issue Type:

Re: [ANNOUNCE] Apache Flink 1.13.0 released

Thanks for Dawid and Guowei's great work, and thanks for everyone involved for this release. Best Yun Tang From: Xintong Song Sent: Thursday, May 6, 2021 12:08 To: user ; dev Subject: Re: [ANNOUNCE] Apache Flink 1.13.0 released Thanks Dawid & Guowei as the