[jira] [Created] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-10-08 Thread JasonLee (Jira)
JasonLee created FLINK-24490: Summary: The sample code is wrong in Apache Kafka Connector page Key: FLINK-24490 URL: https://issues.apache.org/jira/browse/FLINK-24490 Project: Flink Issue Type: B

[jira] [Created] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold

2021-10-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-24489: --- Summary: The size of entryCache in the SharedBuffer should be defined with a threshold Key: FLINK-24489 URL: https://issues.apache.org/jira/browse/FLINK-24489 Project:

Re: What's the purpose of uniqueId in FileWriterBucket

2021-10-08 Thread wu shaoj
If flink job recover from previous checkpoint/savepoint, will it re-output records to a different file with same partFileIndex? And can we upgrade flink to 1.4 smoothly? From: Yun Gao Date: Friday, October 8, 2021 at 22:43 To: wu shaoj , dev@flink.apache.org Subject: Re: What's the purpose of

Re: [DISCUSS] Releasing Flink 1.13.3

2021-10-08 Thread Leonard Xu
> Hi Leonard and Chesnay, > > Can we start with the preparation for the release and get a RC out? I did a > quick check and there are no open blockers and 2 critical open items Hi, Martijn I agree that FLINK-23496 and FLINK-17914 are not the blockers for 1.13.3 release. And I also checked the

Re: What's the purpose of uniqueId in FileWriterBucket

2021-10-08 Thread Yun Gao
Hi Wu, The uid is used to distinguish between the different subtasks, if removed, the different subtasks of the filesink would have name conflicts if they writes to the same bucket, thus the uid should be necessary if there are multiple subtasks. Best, Yun --Original Mail --

Re: 退订

2021-10-08 Thread Leonard Xu
Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev@flink.apache.org, you can refer[1] for more details. [1]https://flink.apache.org/zh/community.html#section > 在 2021年10月8日，14:14，王卫光 写道： > >  退订，谢谢！

[jira] [Created] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-08 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24488: --- Summary: KafkaRecordSerializationSchemaBuilder does not forward timestamp Key: FLINK-24488 URL: https://issues.apache.org/jira/browse/FLINK-24488 Project: Flink

Flink Cassandra sink connector doesn't support Apache Cassandra 4.0

2021-10-08 Thread Purushotham Pushpavanthar
Hi Team, Looks like Flink Cassandra Sink connector is still using datastax driver v3.0.0 which apparently doesn't support Apache Cassandra 4.0. Is there a plan to support this update? If there is no one working on this, can I create a Jira and work on it? Regards, Purushotham Pushpavanthar

Re: First contribution - FLINK-24389

2021-10-08 Thread Nikolay Izhikov
> I have assigned this ticket to you. Thanks, Jark. Patch [1] for the issue is ready. Please, review. [1] https://github.com/apache/flink/pull/17438 > 8 окт. 2021 г., в 12:01, Jark Wu написал(а): > > Hi Nikolay, > > I have assigned this ticket to you. Welcome contribution. > > Usually, you

[jira] [Created] (FLINK-24487) Add DELETE endpoint for operation results

2021-10-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24487: Summary: Add DELETE endpoint for operation results Key: FLINK-24487 URL: https://issues.apache.org/jira/browse/FLINK-24487 Project: Flink Issue Type:

[jira] [Created] (FLINK-24486) Configurable async operation result cache timeout

2021-10-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24486: Summary: Configurable async operation result cache timeout Key: FLINK-24486 URL: https://issues.apache.org/jira/browse/FLINK-24486 Project: Flink Iss

[jira] [Created] (FLINK-24485) COUNT(DISTINCT) should support binary field

2021-10-08 Thread Haohui Mai (Jira)
Haohui Mai created FLINK-24485: -- Summary: COUNT(DISTINCT) should support binary field Key: FLINK-24485 URL: https://issues.apache.org/jira/browse/FLINK-24485 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-24484) Support manual cleanup of async operation results

2021-10-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24484: Summary: Support manual cleanup of async operation results Key: FLINK-24484 URL: https://issues.apache.org/jira/browse/FLINK-24484 Project: Flink Iss

Re: [DISCUSS] Releasing Flink 1.13.3

2021-10-08 Thread Martijn Visser
Hi Leonard and Chesnay, Can we start with the preparation for the release and get a RC out? I did a quick check and there are no open blockers and 2 critical open items: * https://issues.apache.org/jira/browse/FLINK-23946 was already discussed previously and depends on https://issues.apache.org/j

[jira] [Created] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

2021-10-08 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24483: -- Summary: Document what is Public API and what compatibility guarantees Flink is providing Key: FLINK-24483 URL: https://issues.apache.org/jira/browse/FLINK-24483

[jira] [Created] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

2021-10-08 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-24482: - Summary: KafkaShuffleTestBase.testMetrics fails on Azure Key: FLINK-24482 URL: https://issues.apache.org/jira/browse/FLINK-24482 Project: Flink Issue Type:

[jira] [Created] (FLINK-24481) Translit buffer debloater documenation to chinese

2021-10-08 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24481: - Summary: Translit buffer debloater documenation to chinese Key: FLINK-24481 URL: https://issues.apache.org/jira/browse/FLINK-24481 Project: Flink I

Re: First contribution - FLINK-24389

2021-10-08 Thread Jark Wu
Hi Nikolay, I have assigned this ticket to you. Welcome contribution. Usually, you can comment under the JIRA issue, and committer will assign the issue to you. Best, Jark On Fri, 8 Oct 2021 at 16:32, Nikolay Izhikov wrote: > Hello. > > I want to contribute to the Flink. > > FLINK-24389 [1] l

First contribution - FLINK-24389

2021-10-08 Thread Nikolay Izhikov
Hello. I want to contribute to the Flink. FLINK-24389 [1] looks link good ticket to start. Can commiter, please, assign ticket to me? Jira ID - nizhikov. [1] https://issues.apache.org/jira/browse/FLINK-24389