[jira] [Created] (FLINK-32022) Source level scaling is not applied to operators with chaining applied

Tan Kim created FLINK-32022: --- Summary: Source level scaling is not applied to operators with chaining applied Key: FLINK-32022 URL: https://issues.apache.org/jira/browse/FLINK-32022 Project: Flink

[jira] [Created] (FLINK-32021) Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer.

Hongshun Wang created FLINK-32021: - Summary: Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer. Key: FLINK-32021 URL: https://issues.apache.org/jira/browse/FLINK-32021

[jira] [Created] (FLINK-32020) Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288

Hongshun Wang created FLINK-32020: - Summary: Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288 Key: FLINK-32020 URL: https://issues.apache.org/jira/browse/FLINK-32020

[jira] [Created] (FLINK-32019) EARLIEST offset strategy for partitions discoveried later based on FLIP-288

Hongshun Wang created FLINK-32019: - Summary: EARLIEST offset strategy for partitions discoveried later based on FLIP-288 Key: FLINK-32019 URL: https://issues.apache.org/jira/browse/FLINK-32019

[jira] [Created] (FLINK-32018) Many builds of benchmark have been interrupted since 20230428

Yanfei Lei created FLINK-32018: -- Summary: Many builds of benchmark have been interrupted since 20230428 Key: FLINK-32018 URL: https://issues.apache.org/jira/browse/FLINK-32018 Project: Flink

[jira] [Created] (FLINK-32017) DISTINCT COUNT result is incorrect with ttl

Bo Cui created FLINK-32017: -- Summary: DISTINCT COUNT result is incorrect with ttl Key: FLINK-32017 URL: https://issues.apache.org/jira/browse/FLINK-32017 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-32016) Logs are printed as disabled even if the autoscaler option is true

Tan Kim created FLINK-32016: --- Summary: Logs are printed as disabled even if the autoscaler option is true Key: FLINK-32016 URL: https://issues.apache.org/jira/browse/FLINK-32016 Project: Flink

[jira] [Created] (FLINK-32015) Flink does not fail SSL Handshake when expired cert is used

Dhruv Patel created FLINK-32015: --- Summary: Flink does not fail SSL Handshake when expired cert is used Key: FLINK-32015 URL: https://issues.apache.org/jira/browse/FLINK-32015 Project: Flink

[jira] [Created] (FLINK-32014) Cassandra source documentation is missing

Etienne Chauchot created FLINK-32014: Summary: Cassandra source documentation is missing Key: FLINK-32014 URL: https://issues.apache.org/jira/browse/FLINK-32014 Project: Flink Issue

[jira] [Created] (FLINK-32013) Moves DefaultLeaderElectionService.startLeaderElectionBackend() into HAServices

Matthias Pohl created FLINK-32013: - Summary: Moves DefaultLeaderElectionService.startLeaderElectionBackend() into HAServices Key: FLINK-32013 URL: https://issues.apache.org/jira/browse/FLINK-32013

[jira] [Created] (FLINK-32012) Operator failed to rollback due to missing HA metadata

Nicolas Fraison created FLINK-32012: --- Summary: Operator failed to rollback due to missing HA metadata Key: FLINK-32012 URL: https://issues.apache.org/jira/browse/FLINK-32012 Project: Flink

[jira] [Created] (FLINK-32011) flink1.15.2 loaded all the data in the table in mysql5.7

xueyongyang created FLINK-32011: --- Summary: flink1.15.2 loaded all the data in the table in mysql5.7 Key: FLINK-32011 URL: https://issues.apache.org/jira/browse/FLINK-32011 Project: Flink Issue

[jira] [Created] (FLINK-32010) KubernetesLeaderRetrievalDriver always waits for lease update to resolve leadership

David Morávek created FLINK-32010: - Summary: KubernetesLeaderRetrievalDriver always waits for lease update to resolve leadership Key: FLINK-32010 URL: https://issues.apache.org/jira/browse/FLINK-32010

[jira] [Created] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

hanjie created FLINK-32009: -- Summary: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout Key: FLINK-32009 URL: https://issues.apache.org/jira/browse/FLINK-32009

[VOTE] Release flink-connector-cassandra 3.1.0, release candidate #2

Hi everyone, Please review and vote on the release candidate #2 for the version 3.1.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

Re: [VOTE] Release flink-connector-cassandra v3.1.0, release candidate #1

Thanks Etienne, To reiterate, this vote is closed. I will start the RC2. Danny On Thu, May 4, 2023 at 9:45 AM Etienne Chauchot wrote: > @Danny, the fix is merged and the ticket is closed. > > You can open a RC2 whenever you want. > > Best > > Etienne > > Le 04/05/2023 à 06:17, Leonard Xu a

[ANNOUNCE] Apache flink-connector-jdbc 3.1.0 for Flink 1.16/1.17 released

The Apache Flink community is very happy to announce the release of Apache flink-connector-jdbc 3.1.0. This connector supports Flink 1.16 and 1.17. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

Hi everyone, It seems there are no more questions unresolved. So I would like to start a vote on May 8th at 10:00 AM GMT. Please let me know if you have any concerns, thanks! Best, Zakelly On Fri, May 5, 2023 at 4:03 PM Rui Fan <1996fan...@gmail.com> wrote: > > Hi Zakelly, > > Thanks for the

[RESULT] [VOTE] flink-connector-jdbc 3.1.0, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 6 approving votes, 3 of which are binding: * Elphas Toringepi * Hong Teoh * Benchao Li * Danny Cranmer (binding) * Martijn Visser (binding) * Leonard Xu (binding) There are no disapproving votes. Thanks everyone!

Re: [VOTE] Release flink-connector-jdbc v3.1.0, release candidate #1

Thanks all, this vote is now closed. I will announce the results in a separate thread. Danny On Thu, May 4, 2023 at 4:54 AM Leonard Xu wrote: > +1 (binding) > > - built from source code succeeded > - verified signatures > - verified hashsums > - checked Github release tag > - checked release

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

Hi Zakelly, Thanks for the clarification! Currently, I understand what you mean, and LGTM. Best, Rui Fan On Fri, May 5, 2023 at 12:27 PM Zakelly Lan wrote: > Hi all, > > @Yun Tang and I have an offline discussion, and we agreed that: > > 1. The design of this FLIP is pretty much like the

[DISCUSS] FLIP-310:use VARINT and ZIGZAG to encode ROWDATA in state

Hi Guys, I have created a FLIP WIKI FLIP-310 , and documented my thinking about using the varint format in FLINK state to improve the FLINK state performance. Would you please

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.1, release candidate #1

+1 (non-binding) - Verified sha512 checksum matches file archive. - Verified file archive is signed and signature is authorized. - Verified no binaries exist in the source archive. - Verified source archive is consistent with Github source code with tag v3.0.1-rc1, at commit

Re: [VOTE] Release flink-connector-rabbitmq v3.0.1, release candidate #1

Sorry, the above report is supposed for flink-connector-gpc-pubsub-3.0.1 - Here is the check for this one: +1 (non-binding) - Verified sha512 checksum matches file archive. - Verified file archive is signed and signature is authenticated. - Verified no binaries exist in the

Re: [VOTE] Release flink-connector-rabbitmq v3.0.1, release candidate #1

+1 (non-binding) - Verified sha512 checksum matches file archive. - Verified file archive is signed and signature is authorized. - Verified no binaries exist in the source archive. - Verified source archive is consistent with Github source code with tag v3.0.1-rc1, at commit

Re: 您好，退订

Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev@flink.apache.org, and you can refer[1][2] for more details. 请发送任意内容的邮件到 dev-unsubscr...@flink.apache.org 地址来取消订阅来自 dev@flink.apache.org 邮件组的邮件，你可以参考[1][2] 管理邮件订阅。 Best, Leonard

[jira] [Created] (FLINK-32008) Protobuf format throws exception with Map datatype

Xuannan Su created FLINK-32008: -- Summary: Protobuf format throws exception with Map datatype Key: FLINK-32008 URL: https://issues.apache.org/jira/browse/FLINK-32008 Project: Flink Issue Type:

Re: 您好，退订

你好，可以通过发送包含任意内容的邮件到 dev-unsubscr...@flink.apache.org 来取消dev订阅。 Best, Biao Geng Fang jun 于2023年5月5日周五 14:07写道： > > > Sent from my iPhone >

Re: 退订

你好，可以通过发送包含任意内容的邮件到 dev-unsubscr...@flink.apache.org 来取消dev订阅。 Best, Biao Geng houyui <2008-ho...@163.com> 于2023年5月5日周五 13:33写道： > 您好： >退订！