[jira] [Created] (FLINK-22423) Log error cause for state transition in ExecutionGraph

2021-04-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22423: Summary: Log error cause for state transition in ExecutionGraph Key: FLINK-22423 URL: https://issues.apache.org/jira/browse/FLINK-22423 Project: Flink

[jira] [Created] (FLINK-22424) Writing to already released buffers potentially causing data corruption

2021-04-23 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-22424: -- Summary: Writing to already released buffers potentially causing data corruption Key: FLINK-22424 URL: https://issues.apache.org/jira/browse/FLINK-22424 Project:

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-23 Thread Konstantin Knauf
Congratulations! On Fri, Apr 23, 2021 at 8:31 AM Yu Li wrote: > Congratulations Rui! > > Best Regards, > Yu > > > On Fri, 23 Apr 2021 at 10:40, Guowei Ma wrote: > > > Congratulations, Rui! > > Best, > > Guowei > > > > > > On Fri, Apr 23, 2021 at 10:38 AM Yun Tang wrote: > > > > > Congratulatio

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-23 Thread Yang Wang
Congratulations Rui! Best, Yang Konstantin Knauf 于2021年4月23日周五 下午4:05写道: > Congratulations! > > On Fri, Apr 23, 2021 at 8:31 AM Yu Li wrote: > > > Congratulations Rui! > > > > Best Regards, > > Yu > > > > > > On Fri, 23 Apr 2021 at 10:40, Guowei Ma wrote: > > > > > Congratulations, Rui! > >

[jira] [Created] (FLINK-22425) allowedLateness and sideOutput not having an effect

2021-04-23 Thread Matthias (Jira)
Matthias created FLINK-22425: Summary: allowedLateness and sideOutput not having an effect Key: FLINK-22425 URL: https://issues.apache.org/jira/browse/FLINK-22425 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22426) Reduce usage of TableSchema in the planner

2021-04-23 Thread Timo Walther (Jira)
Timo Walther created FLINK-22426: Summary: Reduce usage of TableSchema in the planner Key: FLINK-22426 URL: https://issues.apache.org/jira/browse/FLINK-22426 Project: Flink Issue Type: Sub-ta

[DISCUSS] Add async backpressure support to FlinkKafkaProducer

2021-04-23 Thread Wenhao Ji
Hi everyone, I recently came across the following exception when dealing with a job failure, which uses the Flink as its sink. ``` org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send data to Kafka: Expiring #N record(s) for TOPIC-PARTITION:#N ms has passed since batch

[jira] [Created] (FLINK-22427) Support default value option to simplify data clean process

2021-04-23 Thread Jira
张超明 created FLINK-22427: --- Summary: Support default value option to simplify data clean process Key: FLINK-22427 URL: https://issues.apache.org/jira/browse/FLINK-22427 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-22428) Translate timezone page to Chinese

2021-04-23 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-22428: -- Summary: Translate timezone page to Chinese Key: FLINK-22428 URL: https://issues.apache.org/jira/browse/FLINK-22428 Project: Flink Issue Type: Task Com

[DISCUSS] Feedback Collection Jira Bot

2021-04-23 Thread Konstantin Knauf
Hi everyone, After some offline conversations, I think, it makes sense to already open this thread now in order to collect feedback and suggestions around the Jira Bot. The following two changes I will do right away: * increase "stale-assigned.stale-days" to 14 days (Marta, Stephan, Nico have pr

[jira] [Created] (FLINK-22429) Exlude Sub-Tasks in all bot "stale-unassigned" rule of Jira Bot

2021-04-23 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22429: Summary: Exlude Sub-Tasks in all bot "stale-unassigned" rule of Jira Bot Key: FLINK-22429 URL: https://issues.apache.org/jira/browse/FLINK-22429 Project: Flin

[jira] [Created] (FLINK-22430) Increase "stale-assigned.stale-days" to 14

2021-04-23 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22430: Summary: Increase "stale-assigned.stale-days" to 14 Key: FLINK-22430 URL: https://issues.apache.org/jira/browse/FLINK-22430 Project: Flink Issue Type

[jira] [Created] (FLINK-22431) AdaptiveScheduler does not log failure cause when recovering

2021-04-23 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22431: - Summary: AdaptiveScheduler does not log failure cause when recovering Key: FLINK-22431 URL: https://issues.apache.org/jira/browse/FLINK-22431 Project: Flink

[jira] [Created] (FLINK-22432) Update upgrading.md with 1.13.x

2021-04-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22432: Summary: Update upgrading.md with 1.13.x Key: FLINK-22432 URL: https://issues.apache.org/jira/browse/FLINK-22432 Project: Flink Issue Type: New Featu

CFP for ApacheCon 2021 closes in ONE WEEK

2021-04-23 Thread Rich Bowen
[You are receiving this because you're subscribed to one or more dev@ mailing lists for an Apache project, or the ApacheCon Announce list.] Time is running out to submit your talk for ApacheCon 2021. The Call for Presentations for ApacheCon @Home 2021, focused on Europe and North America time zo

[jira] [Created] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler

2021-04-23 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22433: Summary: CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler Key: FLINK-22433 URL: https://issues.apache.org/jira/browse/FLINK-22433 Project: Flink

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

2021-04-23 Thread Chen Qin
Sure, I update jira with exception info. We could follow up from there for technical discussions. https://issues.apache.org/jira/browse/FLINK-10052?focusedCommentId=17330858&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-17330858 On Thu, Apr 22, 2021 at 10:17 PM t

[jira] [Created] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

2021-04-23 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-22434: --- Summary: Dispatcher does not store suspended jobs in execution graph store Key: FLINK-22434 URL: https://issues.apache.org/jira/browse/FLINK-22434 Project: Flink

[jira] [Created] (FLINK-22436) twitter datastream connector gets Invalid 'expires' attribute

2021-04-23 Thread Jason Perez (Jira)
Jason Perez created FLINK-22436: --- Summary: twitter datastream connector gets Invalid 'expires' attribute Key: FLINK-22436 URL: https://issues.apache.org/jira/browse/FLINK-22436 Project: Flink

[jira] [Created] (FLINK-22435) twitter datastream connector gets Invalid 'expires' attribute

2021-04-23 Thread Jason Perez (Jira)
Jason Perez created FLINK-22435: --- Summary: twitter datastream connector gets Invalid 'expires' attribute Key: FLINK-22435 URL: https://issues.apache.org/jira/browse/FLINK-22435 Project: Flink

[jira] [Created] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2021-04-23 Thread zoucao (Jira)
zoucao created FLINK-22437: -- Summary: Miss adding parallesim for filter operator in batch mode Key: FLINK-22437 URL: https://issues.apache.org/jira/browse/FLINK-22437 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22438) add numRecordsOut metric for Async IO

2021-04-23 Thread Zhengqi Zhang (Jira)
Zhengqi Zhang created FLINK-22438: - Summary: add numRecordsOut metric for Async IO Key: FLINK-22438 URL: https://issues.apache.org/jira/browse/FLINK-22438 Project: Flink Issue Type: Improveme

Re: [VOTE] Release 1.13.0, release candidate #1

2021-04-23 Thread Dawid Wysakowicz
Hi, Since publishing the RC1 we've fixed a number of issues including few critical ones such as e.g. FLINK-22001, FLINK-22354, FLINK-22369 to name a few. Therefore I'm cancelling this vote and I will prepare a new RC shortly. Best, Dawid On 18/04/2021 22:54, Guowei Ma wrote: > Hi everyone, > >

[VOTE] Release 1.13.0, release candidate #2

2021-04-23 Thread Dawid Wysakowicz
|Hi everyone,| |Please review and vote on the release candidate #2 for the version 1.13.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

[VOTE] Release 1.12.3, release candidate #1

2021-04-23 Thread Arvid Heise
Hi everyone, Please review and vote on the release candidate #1 for the version 1.12.3, 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], *

[jira] [Created] (FLINK-22439) UnalignedCheckpointITCase hangs

2021-04-23 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22439: - Summary: UnalignedCheckpointITCase hangs Key: FLINK-22439 URL: https://issues.apache.org/jira/browse/FLINK-22439 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-22440) UpsertKafkaTableITCase fail due to create topic timeout

2021-04-23 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22440: - Summary: UpsertKafkaTableITCase fail due to create topic timeout Key: FLINK-22440 URL: https://issues.apache.org/jira/browse/FLINK-22440 Project: Flink Issue Type: