[jira] [Created] (FLINK-33017) Nightly run for Flink Kafka connector fails

2023-09-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33017: -- Summary: Nightly run for Flink Kafka connector fails Key: FLINK-33017 URL: https://issues.apache.org/jira/browse/FLINK-33017 Project: Flink Issue Type: B

[jira] [Created] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33018: -- Summary: GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed Key: FLINK-33018 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-33019) Pulsar tests hangs during nightly builds

2023-09-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33019: -- Summary: Pulsar tests hangs during nightly builds Key: FLINK-33019 URL: https://issues.apache.org/jira/browse/FLINK-33019 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33020) OpensearchSinkTest.testAtLeastOnceSink timed out

2023-09-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33020: -- Summary: OpensearchSinkTest.testAtLeastOnceSink timed out Key: FLINK-33020 URL: https://issues.apache.org/jira/browse/FLINK-33020 Project: Flink Issue Ty

[jira] [Created] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33021: -- Summary: AWS nightly builds fails on architecture tests Key: FLINK-33021 URL: https://issues.apache.org/jira/browse/FLINK-33021 Project: Flink Issue Type

[jira] [Created] (FLINK-33022) When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs

2023-09-04 Thread Matt Wang (Jira)
Matt Wang created FLINK-33022: - Summary: When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs Key: FLINK-33022 URL: https://issues.apache.org/jira/browse/FLINK-330

[jira] [Created] (FLINK-33023) [JUnit5 Migration] Module: flink-table-planner (TableTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33023: -- Summary: [JUnit5 Migration] Module: flink-table-planner (TableTestBase) Key: FLINK-33023 URL: https://issues.apache.org/jira/browse/FLINK-33023 Project: Flink I

Re: [VOTE] Release flink-connector-hbase v3.0.0, release candidate 2

2023-09-04 Thread Ahmed Hamdy
Hi Martijn, +1 (non-binding) - verified Checksums and signatures - no binaries in source - Checked NOTICE files contains migrated artifacts - tag is correct - Approved Web PR Best Regards Ahmed Hamdy On Fri, 1 Sept 2023 at 15:35, Martijn Visser wrote: > Hi everyone, > > Please review and vote

[jira] [Created] (FLINK-33024) [JUnit5 Migration] Module: flink-table-planner (TableTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33024: -- Summary: [JUnit5 Migration] Module: flink-table-planner (TableTestBase) Key: FLINK-33024 URL: https://issues.apache.org/jira/browse/FLINK-33024 Project: Flink I

[jira] [Created] (FLINK-33025) BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP

2023-09-04 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33025: --- Summary: BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP Key: FLINK-33025 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-33026) The chinese doc of sql 'Performance Tuning' has a wrong title in the index page

2023-09-04 Thread lincoln lee (Jira)
lincoln lee created FLINK-33026: --- Summary: The chinese doc of sql 'Performance Tuning' has a wrong title in the index page Key: FLINK-33026 URL: https://issues.apache.org/jira/browse/FLINK-33026 Project

[jira] [Created] (FLINK-33027) Users should be able to change parallelism of excluded vertices

2023-09-04 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-33027: -- Summary: Users should be able to change parallelism of excluded vertices Key: FLINK-33027 URL: https://issues.apache.org/jira/browse/FLINK-33027 Project: Flink

Re: [VOTE] Release flink-connector-hbase v3.0.0, release candidate 2

2023-09-04 Thread Sergey Nuyanzin
Hi Martijn, thanks a lot for taking this +1 (non-binding) - checked signatures and checksums - checked that no binaries - checked NOTICE and LICENSE - checked web PR there is one minor I noticed: the connector still uses "io.github.zentol .flink" for flink-connector-parent I submitted a PR[1] to

Re: [VOTE] Release flink-connector-hbase v3.0.0, release candidate 2

2023-09-04 Thread Samrat Deb
Hi, +1 (non-binding) Verified NOTICE files Verified CheckSum and signatures Glanced through PR[1] , Looks good to me Bests, Samrat [1]https://github.com/apache/flink-web/pull/591 > On 04-Sep-2023, at 2:22 PM, Ahmed Hamdy wrote: > > Hi Martijn, > +1 (non-binding) > > - verified Check

Re: [DISCUSS] Drop python 3.7 support in 1.19

2023-09-04 Thread Sergey Nuyanzin
+1, Thanks for looking into this. On Mon, Sep 4, 2023 at 8:38 AM Gyula Fóra wrote: > +1 > Thanks for looking into this. > > Gyula > > On Mon, Sep 4, 2023 at 8:26 AM Matthias Pohl .invalid> > wrote: > > > Thanks Gabor for looking into it. It sounds reasonable to me as well. > > > > +1 > > > > On

[DISCUSS] FLIP-360: Merging ExecutionGraphInfoStore and JobResultStore into a single component

2023-09-04 Thread Matthias Pohl
Hi everyone, I want to open the discussion on FLIP-360 [1]. The goal of this FLIP is to combine the two very similar components ExecutionGraphInfoStore and JobResultStore into a single component. The benefit of this effort would be to expose the metadata of a globally-terminated job even in cases

[jira] [Created] (FLINK-33028) FLIP-348: Make expanding behavior of virtual metadata columns configurable

2023-09-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-33028: Summary: FLIP-348: Make expanding behavior of virtual metadata columns configurable Key: FLINK-33028 URL: https://issues.apache.org/jira/browse/FLINK-33028 Project: F

[jira] [Created] (FLINK-33029) Drop python 3.7 support

2023-09-04 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-33029: - Summary: Drop python 3.7 support Key: FLINK-33029 URL: https://issues.apache.org/jira/browse/FLINK-33029 Project: Flink Issue Type: New Feature C

[jira] [Created] (FLINK-33030) Add python 3.11 support

2023-09-04 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-33030: - Summary: Add python 3.11 support Key: FLINK-33030 URL: https://issues.apache.org/jira/browse/FLINK-33030 Project: Flink Issue Type: New Feature C

Re: [DISCUSS] Drop python 3.7 support in 1.19

2023-09-04 Thread Gabor Somogyi
Thanks for all the responses! Based on the suggestions I've created the following jiras and started to work on them: * https://issues.apache.org/jira/browse/FLINK-33029 * https://issues.apache.org/jira/browse/FLINK-33030 The reason why I've split them is to separate the concerns and reduce the am

[DISCUSS] Add config to enable job stop with savepoint on exceeding tolerable checkpoint Failures

2023-09-04 Thread Dongwoo Kim
Hi all, I have a proposal that aims to enhance the flink application's resilience in cases of unexpected failures in checkpoint storages like S3 or HDFS, *[Background]* When using self managed S3-compatible object storage, we faced checkpoint async failures lasting for an extended period more than

Re: [DISCUSS] FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag

2023-09-04 Thread Jing Ge
Hi Xuannan, Thanks for the clarification. 3. Event time and process time are two different things. It might be rarely used, but conceptually, users can process data in the past within a specific time range in the streaming mode. All data before that range will be considered as backlog and needed

Proposal for Implementing Keyed Watermarks in Apache Flink

2023-09-04 Thread Tawfek Yasser Tawfek
Dear Apache Flink Development Team, I hope this email finds you well. I am writing to propose an exciting new feature for Apache Flink that has the potential to significantly enhance its capabilities in handling unbounded streams of events, particularly in the context of event-time windowing.

[jira] [Created] (FLINK-33031) [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33031: -- Summary: [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase) Key: FLINK-33031 URL: https://issues.apache.org/jira/browse/FLINK-33031 Project: Flink

[jira] [Created] (FLINK-33032) [JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33032: -- Summary: [JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase) Key: FLINK-33032 URL: https://issues.apache.org/jira/browse/FLINK-33032 Project: Flink

Re: [DISCUSS] Drop python 3.7 support in 1.19

2023-09-04 Thread Jing Ge
+1 @Dian should we add support of python 3.11 Best regards, Jing On Mon, Sep 4, 2023 at 3:39 PM Gabor Somogyi wrote: > Thanks for all the responses! > > Based on the suggestions I've created the following jiras and started to > work on them: > * https://issues.apache.org/jira/browse/FLINK-3302

[jira] [Created] (FLINK-33033) Add haservice micro benchmark for olap

2023-09-04 Thread Fang Yong (Jira)
Fang Yong created FLINK-33033: - Summary: Add haservice micro benchmark for olap Key: FLINK-33033 URL: https://issues.apache.org/jira/browse/FLINK-33033 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33034) Incorrect StateBackendTestBase#testGetKeysAndNamespaces

2023-09-04 Thread Dmitriy Linevich (Jira)
Dmitriy Linevich created FLINK-33034: Summary: Incorrect StateBackendTestBase#testGetKeysAndNamespaces Key: FLINK-33034 URL: https://issues.apache.org/jira/browse/FLINK-33034 Project: Flink