Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

Thanks for the feedback! > > # 1 Flink Native vs Standalone integration > Maybe we should make this more clear in the FLIP but we agreed to do the > first version of the operator based on the native integration. > While this clearly does not cover all use-cases and requirements, it seems > this

[jira] [Created] (FLINK-25861) Move states of AbstractAvroBulkFormat into its reader

Caizhi Weng created FLINK-25861: --- Summary: Move states of AbstractAvroBulkFormat into its reader Key: FLINK-25861 URL: https://issues.apache.org/jira/browse/FLINK-25861 Project: Flink Issue

[jira] [Created] (FLINK-25860) Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid blocking main thread

Yingjie Cao created FLINK-25860: --- Summary: Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid blocking main thread Key: FLINK-25860 URL:

Re: [VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

+1 (non-binding) - verified checksum and signatures - build from source code - version checked - test docker PR - test flink-statefun-playground/greeter with 3.2.0 Misc, do we want to upgrade flink-statefun-playground together? Currently the README information is a little behind. B.R. Mingmin

[jira] [Created] (FLINK-25859) Add documentation for DynamoDB Async Sink

Yuri Gusev created FLINK-25859: -- Summary: Add documentation for DynamoDB Async Sink Key: FLINK-25859 URL: https://issues.apache.org/jira/browse/FLINK-25859 Project: Flink Issue Type: New

[jira] [Created] (FLINK-25858) Remove ArchUnit rules for JUnit 4 in ITCaseRules the JUnit 4->5 migration is closed

Jing Ge created FLINK-25858: --- Summary: Remove ArchUnit rules for JUnit 4 in ITCaseRules the JUnit 4->5 migration is closed Key: FLINK-25858 URL: https://issues.apache.org/jira/browse/FLINK-25858 Project:

Re: [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

As there have been only votes in favour of pushing the feature freeze we pushed it to the 14th of February. The bi-weekly sync meeting will happen every week now. A nice holiday to all the Chinese contributors. Best, Joe > On 26.01.2022, at 09:26, David Morávek wrote: > > +1, especially for

Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

Hi All! Thanks for the questions, there are still quite a few unknowns and decisions to be made but here are my current thoughts: # 1 Flink Native vs Standalone integration Maybe we should make this more clear in the FLIP but we agreed to do the first version of the operator based on the native

[jira] [Created] (FLINK-25857) Add committer metrics to track the status of committables

Fabian Paul created FLINK-25857: --- Summary: Add committer metrics to track the status of committables Key: FLINK-25857 URL: https://issues.apache.org/jira/browse/FLINK-25857 Project: Flink

[jira] [Created] (FLINK-25856) Fix use of UserDefinedType in from_elements

Huang Xingbo created FLINK-25856: Summary: Fix use of UserDefinedType in from_elements Key: FLINK-25856 URL: https://issues.apache.org/jira/browse/FLINK-25856 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25855) DefaultDeclarativeSlotPool rejects offered slots when the job is restarting

Till Rohrmann created FLINK-25855: - Summary: DefaultDeclarativeSlotPool rejects offered slots when the job is restarting Key: FLINK-25855 URL: https://issues.apache.org/jira/browse/FLINK-25855

[jira] [Created] (FLINK-25854) Annotate legacy FileSource as deprecated

Martijn Visser created FLINK-25854: -- Summary: Annotate legacy FileSource as deprecated Key: FLINK-25854 URL: https://issues.apache.org/jira/browse/FLINK-25854 Project: Flink Issue Type:

[jira] [Created] (FLINK-25853) Annotate current JDBC connector as deprecated to prepare for new JDBC connector

Martijn Visser created FLINK-25853: -- Summary: Annotate current JDBC connector as deprecated to prepare for new JDBC connector Key: FLINK-25853 URL: https://issues.apache.org/jira/browse/FLINK-25853

[jira] [Created] (FLINK-25852) Annotate SourceFunction and SinkFunction as deprecated

Martijn Visser created FLINK-25852: -- Summary: Annotate SourceFunction and SinkFunction as deprecated Key: FLINK-25852 URL: https://issues.apache.org/jira/browse/FLINK-25852 Project: Flink

[jira] [Created] (FLINK-25851) CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP

Etienne Chauchot created FLINK-25851: Summary: CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP Key: FLINK-25851 URL:

[RESULT][VOTE] FLIP-203: Incremental savepoints

Hi, FLIP-203 [1] Has been accepted. There were 4 binding votes and 2 non-binding in favor. None against. Binding: Till Rohrmann Dawid Wysakowicz Konstantin Knauf Yu Li Non-binding: David Moravek Anton Kalashnikov Best, Piotrek [1]

Re: [VOTE] FLIP-203: Incremental savepoints

Hi, Thank you for casting your votes. I have forgotten to set the voting period, but let's implicitly assume it was 3 days from the creation of the voting thread. FLIP-203 [1] Has been accepted. There were 4 binding votes and 2 non-binding in favor. None against. Best, Piotrek [1]

[jira] [Created] (FLINK-25850) Consider notifying nested state backend about checkpoint abortion

Roman Khachatryan created FLINK-25850: - Summary: Consider notifying nested state backend about checkpoint abortion Key: FLINK-25850 URL: https://issues.apache.org/jira/browse/FLINK-25850 Project:

[jira] [Created] (FLINK-25849) Differentiate TaskManager sessions

Till Rohrmann created FLINK-25849: - Summary: Differentiate TaskManager sessions Key: FLINK-25849 URL: https://issues.apache.org/jira/browse/FLINK-25849 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] flink-shaded 15.0 released

Thanks a lot for driving this release Chesnay! Cheers, Till On Thu, Jan 27, 2022 at 10:33 AM Francesco Guardiani < france...@ververica.com> wrote: > Thanks Chesnay for this! > > FG > > On Mon, Jan 24, 2022 at 11:20 AM David Morávek wrote: > > > That's a great news Chesnay, thanks for driving

Re: [ANNOUNCE] flink-shaded 15.0 released

Thanks Chesnay for this! FG On Mon, Jan 24, 2022 at 11:20 AM David Morávek wrote: > That's a great news Chesnay, thanks for driving this! This should unblock > some ongoing Flink efforts +1 > > Best, > D. > > On Mon, Jan 24, 2022 at 10:58 AM Chesnay Schepler > wrote: > > > Hello everyone, > >

[jira] [Created] (FLINK-25848) [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied

Danny Cranmer created FLINK-25848: - Summary: [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied Key: FLINK-25848 URL: https://issues.apache.org/jira/browse/FLINK-25848

[jira] [Created] (FLINK-25847) KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure

Yun Gao created FLINK-25847: --- Summary: KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure Key: FLINK-25847 URL: https://issues.apache.org/jira/browse/FLINK-25847

[jira] [Created] (FLINK-25846) Async Sink does not gracefully shutdown on Cancel

Danny Cranmer created FLINK-25846: - Summary: Async Sink does not gracefully shutdown on Cancel Key: FLINK-25846 URL: https://issues.apache.org/jira/browse/FLINK-25846 Project: Flink Issue

[jira] [Created] (FLINK-25845) Expose plan via SQL COMPILE / EXECUTE PLAN

Timo Walther created FLINK-25845: Summary: Expose plan via SQL COMPILE / EXECUTE PLAN Key: FLINK-25845 URL: https://issues.apache.org/jira/browse/FLINK-25845 Project: Flink Issue Type:

[jira] [Created] (FLINK-25844) Expose plan via StatementSet.compilePlan

Timo Walther created FLINK-25844: Summary: Expose plan via StatementSet.compilePlan Key: FLINK-25844 URL: https://issues.apache.org/jira/browse/FLINK-25844 Project: Flink Issue Type:

[jira] [Created] (FLINK-25843) Expose plan via Table.compilePlan/TableEnvironment.fromPlan

Timo Walther created FLINK-25843: Summary: Expose plan via Table.compilePlan/TableEnvironment.fromPlan Key: FLINK-25843 URL: https://issues.apache.org/jira/browse/FLINK-25843 Project: Flink

[jira] [Created] (FLINK-25842) [v2] FLIP-158: Generalized incremental checkpoints

Roman Khachatryan created FLINK-25842: - Summary: [v2] FLIP-158: Generalized incremental checkpoints Key: FLINK-25842 URL: https://issues.apache.org/jira/browse/FLINK-25842 Project: Flink

[jira] [Created] (FLINK-25841) Expose plan via TableEnvironment.compilePlanSql/executePlan

Timo Walther created FLINK-25841: Summary: Expose plan via TableEnvironment.compilePlanSql/executePlan Key: FLINK-25841 URL: https://issues.apache.org/jira/browse/FLINK-25841 Project: Flink

[jira] [Created] (FLINK-25840) Add semantic test support in the connector testframe

Hang Ruan created FLINK-25840: - Summary: Add semantic test support in the connector testframe Key: FLINK-25840 URL: https://issues.apache.org/jira/browse/FLINK-25840 Project: Flink Issue Type: