[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-07-18 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887849#comment-16887849 ] Brachi Packter commented on BEAM-7357: -- [~aromanenko] Sure, it was by mistake. > Kinesis IO.write

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-07-18 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887836#comment-16887836 ] Alexey Romanenko commented on BEAM-7357: [~brachi_packter] Thanks for checking this. Since this

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-07-16 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885929#comment-16885929 ] Brachi Packter commented on BEAM-7357: -- [~aromanenko] Still happens, can't run Data Flow with the

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-18 Thread Anton Kedin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867120#comment-16867120 ] Anton Kedin commented on BEAM-7357: --- [~aromanenko] cool, resolving this one in favor of BEAM-7589 then

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-18 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867028#comment-16867028 ] Alexey Romanenko commented on BEAM-7357: [~brachi_packter] Thank you for details, I'll get back to

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-17 Thread Anton Kedin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865844#comment-16865844 ] Anton Kedin commented on BEAM-7357: --- 2.14 release branch will be cut in 2 days, does it make sense to

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-16 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864956#comment-16864956 ] Brachi Packter commented on BEAM-7357: -- I get same Same error:  [0x1728][0x7f13ed4c4700]

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-14 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864134#comment-16864134 ] Alexey Romanenko commented on BEAM-7357: [~brachi_packter] What kind of error do you have in this

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-13 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863278#comment-16863278 ] Alexey Romanenko commented on BEAM-7357: Hmm, interesting, seems it's a different issue. This is

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-13 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16862850#comment-16862850 ] Brachi Packter commented on BEAM-7357: -- [~aromanenko] I think I find what makes the shard map update

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-11 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16861009#comment-16861009 ] Brachi Packter commented on BEAM-7357: -- I still get this error. any chance you still call to describe

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-05 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856629#comment-16856629 ] Alexey Romanenko commented on BEAM-7357: [~brachi_packter] I removed this check (since Kinesis

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-03 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854826#comment-16854826 ] Brachi Packter commented on BEAM-7357: -- Ok. Thanks. Let me know when to recheck. On Mon, Jun 3,

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-03 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854817#comment-16854817 ] Alexey Romanenko commented on BEAM-7357: I think you are right and we can eliminate this check at

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-03 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854472#comment-16854472 ] Brachi Packter commented on BEAM-7357: -- This exactly what I used, and also checked that I see in the

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-03 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854431#comment-16854431 ] Alexey Romanenko commented on BEAM-7357: [~brachi_packter] Thank you for testing. Any chance that

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-06-01 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16853799#comment-16853799 ] Brachi Packter commented on BEAM-7357: -- [~aromanenko] Issue still happnes for me. I started 60

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-05-31 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16853173#comment-16853173 ] Alexey Romanenko commented on BEAM-7357: [~brachi_packter] The fix was merged into master. Would

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-05-31 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852940#comment-16852940 ] Alexey Romanenko commented on BEAM-7357: Yes, I'll fix this. Thanks for the report! > Kinesis

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-05-30 Thread Brachi Packter (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851625#comment-16851625 ] Brachi Packter commented on BEAM-7357: -- I found why it is happen, you call in @SetUp method to

[jira] [Commented] (BEAM-7357) Kinesis IO.write throws LimitExceededException

2019-05-23 Thread Alexey Romanenko (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846766#comment-16846766 ] Alexey Romanenko commented on BEAM-7357: Do you see any exceeding of number of incoming records or