Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-07 Thread Roman Khachatryan
> > > > > > > > > > > + dev@ for visibility > > > > > > > > > > > > > > I will investigate further today. > > > > > > > > > > > > > > > > > > > > > On Wed, Jul

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-07 Thread Thomas Weise
fect. >> > > > > > >> > >> > > > > > >> > I think we need to find out whether it has other symptoms >> > > changed >> > > > > > >> besides the performance regression to further fig

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-07 Thread Thomas Weise
ctually I was also suspicious of the point of #snapshotState >>> in >>> > > > previous >>> > > > > > discussions since it indeed cost much time to block normal >>> operator >>> > > > > > processing. >>> >

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-08 Thread Roman Khachatryan
;>> wangzhijiang...@aliyun.com >>>> > > > > .invalid> >>>> > > > > wrote: >>>> > > > > >>>> > > > > > Hi Thomas, >>>> > > > > > >>>> > > > > &g

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-13 Thread Roman Khachatryan
;> > > > > > > I will investigate further today. >>>>> > > > > > > >>>>> > > > > > > >>>>> > > > > > > On Wed, Jul 8, 2020 at 4:42 AM Aljoscha Krettek < >>>>> >

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-13 Thread Thomas Weise
--- >>>>>> > > > > > From:Thomas Weise >>>>>> > > > > > Send Time:2020年7月17日(星期五) 05:29 >>>>>> > > > > > To:dev >>>>>> > > > >

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-14 Thread Piotr Nowojski
o verify? > >>>>>> > > > > > [1] https://issues.apache.org/jira/browse/FLINK-17496 > >>>>>> > > > > > [2] https://issues.apache.org/jira/browse/FLINK-14881 > >>>>>> > > > > > > >>>&g

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-13 Thread Thomas Weise
Best, > > Zhijiang > > > > > > ------ > > From:Thomas Weise > > Send Time:2020年7月7日(星期二) 23:01 > > To:Stephan Ewen > > Cc:Aljoscha Krettek ; Arvid Heise < > ar...@ververica.com>; Zhijiang &

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-16 Thread Thomas Weise
ssing until back pressure the source. >> > Maybe we could dig into the process of sync execution in checkpoint. >> E.g. break down the steps inside respective operator#snapshotState to >> statistic which operation cost most of the time, then >> > we might probably find the roo

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-16 Thread Zhijiang
ebugging if possible. >> > >> > >> > Best, >> > Zhijiang >> > >> > >> > -- >> > From:Thomas Weise >> > Send Time:2020年7月7日(星期二) 23:01 >> > To:St

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-23 Thread Thomas Weise
From:Thomas Weise > Send Time:2020年7月17日(星期五) 05:29 > To:dev > Cc:Zhijiang ; Stephan Ewen ; > Arvid Heise ; Aljoscha Krettek > Subject:Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release > candidate #4) > > Sorry for the delay. > > I confirmed that the r

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-23 Thread Kurt Young
; You mentioned that you already reverted the SDK upgrade to verify no > > changes. Did you also revert the [1] to verify? > > [1] https://issues.apache.org/jira/browse/FLINK-17496 > > [2] https://issues.apache.org/jira/browse/FLINK-14881 > > > > Best, > > Zhijiang > > -- >

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-30 Thread Thomas Weise
ration of > > sync > > > >> checkpoint process in Kinesis sink operator, which would block the > > > normal > > > >> data processing until back pressure the source." > > > >> > > > > >> > That's a consta

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-01 Thread Roman Khachatryan
upgrading amazon-kinesis-producer to 0.14.0 [1] and another is > > for > > > > upgrading aws-sdk-version to 1.11.754 [2]. > > > > You mentioned that you already reverted the SDK upgrade to verify no > > > > changes. Did you also revert the [1] to verify? &

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-06 Thread Thomas Weise
t; > > operations > > > > > inside KinesisProducer implementation provided by amazonaws, which > I > > am > > > > not > > > > > quite familiar with. > > > > > But I noticed there were two upgrades related to it in >