[jira] [Created] (FLINK-28761) BinaryClassificationEvaluator cannot work with unaligned checkpoint

Yunfeng Zhou created FLINK-28761: Summary: BinaryClassificationEvaluator cannot work with unaligned checkpoint Key: FLINK-28761 URL: https://issues.apache.org/jira/browse/FLINK-28761 Project: Flink

[jira] [Created] (FLINK-28762) Support AvroParquetWriters in PyFlink

Juntao Hu created FLINK-28762: - Summary: Support AvroParquetWriters in PyFlink Key: FLINK-28762 URL: https://issues.apache.org/jira/browse/FLINK-28762 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28763) Make savepoint format configurable for upgrades/savepoint operations

Gyula Fora created FLINK-28763: -- Summary: Make savepoint format configurable for upgrades/savepoint operations Key: FLINK-28763 URL: https://issues.apache.org/jira/browse/FLINK-28763 Project: Flink

[jira] [Created] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

Wei Zhong created FLINK-28764: - Summary: Support more than 64 distinct aggregate function calls in one aggregate SQL query Key: FLINK-28764 URL: https://issues.apache.org/jira/browse/FLINK-28764 Project:

[jira] [Created] (FLINK-28765) Create a doc for protobuf format

Suhan Mao created FLINK-28765: - Summary: Create a doc for protobuf format Key: FLINK-28765 URL: https://issues.apache.org/jira/browse/FLINK-28765 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

Huang Xingbo created FLINK-28766: Summary: UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException Key: FLINK-28766 URL: https://issues.apache.org/jira/browse/FLINK-28766 Project

[jira] [Created] (FLINK-28767) SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedError

Huang Xingbo created FLINK-28767: Summary: SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedError Key: FLINK-28767 URL: https://issues.apache.org/jira/browse/FLINK-28767 Project:

[DISCUSS] FLIP-254 Redis Streams connector

Hi everyone, Together with Mohammad we would like to start a discussion thread on FLIP-254 for a Redis Streams connector. This would also be a new connector in its own external connector repository, being https://www.github.com/apache/flink-connector-redis. This repository already exists, because

Re: Re: Re: Re: [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27

Hi, There is currently already a PR submitted to port the JDBC interface to the new interfaces. Can we make sure that this FLIP is being finalized, so that you and other maintainers can work on getting the PRs correct and eventually merged in? Best regards, Martijn Op ma 4 jul. 2022 om 16:38 sc

[DISCUSS] FLIP-255 Introduce pre-aggregated merge to Table Store

Hi everyone, I would like to open a discussion on FLIP-255 Introduce pre-aggregated merge to table store [1]. Pre-aggregation mechanism has been adopted by ma?6?7ny bi?6?7g d?6?7ata system?6?7?6?7s (such as Apache Doris,?6?7  Apache Kylin?6?7 , Druid etc.) to save storage and accelerate the a

[jira] [Created] (FLINK-28768) Update JUnit5 to v5.9.0

Sergey Nuyanzin created FLINK-28768: --- Summary: Update JUnit5 to v5.9.0 Key: FLINK-28768 URL: https://issues.apache.org/jira/browse/FLINK-28768 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-28769) Flink History Server show wrong name of batch jobs

Biao Geng created FLINK-28769: - Summary: Flink History Server show wrong name of batch jobs Key: FLINK-28769 URL: https://issues.apache.org/jira/browse/FLINK-28769 Project: Flink Issue Type: Bug

[RESULT][VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

Hi everyone, FLIP-250: Support Customized Kubernetes Schedulers Proposal [1] has been accepted. >From vote thread[2] , there were 7 votes(+1), 4 of them are binding votes: - Yang Wang (binding) - Martijn Visser (binding) - Kelu Tao (non-binding) - William Wang (non-binding) - MrL (non-binding) -

[jira] [Created] (FLINK-28770) CREATE TABLE AS SELECT supports explain

tartarus created FLINK-28770: Summary: CREATE TABLE AS SELECT supports explain Key: FLINK-28770 URL: https://issues.apache.org/jira/browse/FLINK-28770 Project: Flink Issue Type: Sub-task

Re: [Phishing Risk] [External] [DISCUSS] FLIP-255 Introduce pre-aggregated merge to Table Store

Hi Nathan, Seems a great proposal for table store aggregation. In the example, I think the 'max_field1' should be 1 instead of 2 after the max aggregation in the output result. And there may be a minor typo in the WITH clause, 'max_field2' -> 'max_field1'. Best, Guojun From: "Hannan Kan" Date: M

[jira] [Created] (FLINK-28771) Assign speculative execution attempt with correct CREATED timestamp

Zhu Zhu created FLINK-28771: --- Summary: Assign speculative execution attempt with correct CREATED timestamp Key: FLINK-28771 URL: https://issues.apache.org/jira/browse/FLINK-28771 Project: Flink Is

Re: [Phishing Risk] [External] [DISCUSS] FLIP-255 Introduce pre-aggregated merge to Table Store

Thanks Nathan for starting this discussion. This [1] is a very good requirement to build the materialized view on Flink Table Store. ## Aggregate Functions For 'aggregate-function' = '{sum_field1:sum,max_field2:max}'. Do you refer to any other systems? For us at Flink, a viable approach is someth

Re: [VOTE] FLIP-217: Support watermark alignment of source splits

Hi all, +1 (non-binding). Can't wait to use this feature in Flink! Best, Mason On Sun, Jul 31, 2022 at 10:57 PM Sebastian Mattheis wrote: > Hi everyone, > > I would like to start the vote for FLIP-217 [1]. Thanks for your feedback > and the discussion in [2]. > > FLIP-217 is a follow-up on FLI

[jira] [Created] (FLINK-28772) Port AddJarOperation to Hive dialect

luoyuxia created FLINK-28772: Summary: Port AddJarOperation to Hive dialect Key: FLINK-28772 URL: https://issues.apache.org/jira/browse/FLINK-28772 Project: Flink Issue Type: Sub-task