Pawel Bartoszek created BEAM-3726:
-
Summary: Kinesis Reader: java.lang.IllegalArgumentException:
Attempting to move backwards
Key: BEAM-3726
URL: https://issues.apache.org/jira/browse/BEAM-3726
Projec
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3726:
--
Description:
When the job is restored from savepoint Kinesis Reader throws sometimes
{{java.lang
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3726:
--
Description:
When the job is restored from savepoint Kinesis Reader throws almost always
{{java.
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383570#comment-16383570
]
Pawel Bartoszek commented on BEAM-3726:
---
[~iemejia] we upgraded to Beam 2.3 and Flink
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3726:
--
Description:
When the job is restored from savepoint Kinesis Reader throws almost always
{{java.
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383736#comment-16383736
]
Pawel Bartoszek commented on BEAM-3726:
---
[~iemejia] I have looked into PubSubIO impl
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3726:
--
Attachment: KinesisIO-state.txt
> Kinesis Reader: java.lang.IllegalArgumentException: Attempting
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383763#comment-16383763
]
Pawel Bartoszek commented on BEAM-3726:
---
[~iemejia] I managed to catch this except
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383882#comment-16383882
]
Pawel Bartoszek commented on BEAM-3726:
---
Another think I noticed (I might be complete
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383882#comment-16383882
]
Pawel Bartoszek edited comment on BEAM-3726 at 3/2/18 5:51 PM:
--
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383882#comment-16383882
]
Pawel Bartoszek edited comment on BEAM-3726 at 3/2/18 5:57 PM:
--
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383882#comment-16383882
]
Pawel Bartoszek edited comment on BEAM-3726 at 3/2/18 6:06 PM:
--
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16384564#comment-16384564
]
Pawel Bartoszek commented on BEAM-3726:
---
[~iemejia] I managed to write a test that re
[
https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16384564#comment-16384564
]
Pawel Bartoszek edited comment on BEAM-3726 at 3/3/18 9:00 AM:
--
Pawel Bartoszek created BEAM-3488:
-
Summary: Reduce log noise coming from File sink
Key: BEAM-3488
URL: https://issues.apache.org/jira/browse/BEAM-3488
Project: Beam
Issue Type: Improvement
Pawel Bartoszek created BEAM-3500:
-
Summary: JdbcIO: Improve connection management
Key: BEAM-3500
URL: https://issues.apache.org/jira/browse/BEAM-3500
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333739#comment-16333739
]
Pawel Bartoszek commented on BEAM-3500:
---
[~jbonofre], can you post a link to a branch
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context:*
I want to count how many events of given type(A,B, etc) I receive ev
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context:*
I want to count how many events of given type(A,B, etc) I receive ev
Pawel Bartoszek created BEAM-3863:
-
Summary: AfterProcessingTime trigger doesn't fire reliably
Key: BEAM-3863
URL: https://issues.apache.org/jira/browse/BEAM-3863
Project: Beam
Issue Type: Bu
[
https://issues.apache.org/jira/browse/BEAM-3863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3863:
--
Description:
*Issue*
Beam AfterProcessingTime trigger doesn't fire always reliably after a
conf
[
https://issues.apache.org/jira/browse/BEAM-3863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3863:
--
Description:
*Issue*
Beam AfterProcessingTime trigger doesn't fire always reliably after a
conf
[
https://issues.apache.org/jira/browse/BEAM-3863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3863:
--
Description:
*Issue*
Beam AfterProcessingTime trigger doesn't fire always reliably after a
conf
[
https://issues.apache.org/jira/browse/BEAM-3863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3863:
--
Description:
*Issue*
Beam AfterProcessingTime trigger doesn't fire always reliably after a
conf
[
https://issues.apache.org/jira/browse/BEAM-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403089#comment-16403089
]
Pawel Bartoszek commented on BEAM-3225:
---
[~dawidwys] I think this issue might have be
Pawel Bartoszek created BEAM-2752:
-
Summary: Job fails to checkpoint with kinesis stream as an input
for Flink job
Key: BEAM-2752
URL: https://issues.apache.org/jira/browse/BEAM-2752
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-2752:
--
Description:
Our job is reading from kinesis stream as a job input. Quiet often when the job
is
[
https://issues.apache.org/jira/browse/BEAM-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-2752:
--
Description:
Our job is reading from kinesis stream as a job input. Quiet often when the job
is
Pawel Bartoszek created BEAM-3186:
-
Summary: In-flight data loss when restoring from savepoint
Key: BEAM-3186
URL: https://issues.apache.org/jira/browse/BEAM-3186
Project: Beam
Issue Type: Bu
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Attachment: restore_no_trigger.png
restore_with_trigger.png
> In-flight data loss
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
!restore_no_trigger.png|thumbnail!
!restore_with_trigger.png|thumbnail!
> In-flight
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context: *
I want to count how many events of given type(A,B, etc) I receive ev
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context:*
I want to count how many events of given type(A,B, etc) I receive ev
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Attachment: (was: restore_no_trigger.png)
> In-flight data loss when restoring from savepoint
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Attachment: restore_no_trigger.png
restore_with_trigger.png
> In-flight data loss
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Attachment: (was: restore_with_trigger.png)
> In-flight data loss when restoring from savepoi
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context:*
I want to count how many events of given type(A,B, etc) I receive ev
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context:*
I want to count how many events of given type(A,B, etc) I receive ev
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Description:
*The context:*
I want to count how many events of given type(A,B, etc) I receive ev
Pawel Bartoszek created BEAM-3225:
-
Summary: Non deterministic behaviour of AfterProcessingTime
trigger with multiple group by transformations
Key: BEAM-3225
URL: https://issues.apache.org/jira/browse/BEAM-3225
[
https://issues.apache.org/jira/browse/BEAM-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3225:
--
Description:
*Context*
I run my [test
code|https://gist.github.com/pbartoszek/fe6b1d7501333a2a4
[
https://issues.apache.org/jira/browse/BEAM-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3225:
--
Description:
*Context*
I run my [test
code|https://gist.github.com/pbartoszek/fe6b1d7501333a2a4
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3186:
--
Attachment: restore_with_trigger_b.png
As [~aljoscha] suggested I performed another test depicted
[
https://issues.apache.org/jira/browse/BEAM-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-2752:
--
Affects Version/s: 2.2.0
2.1.0
Description:
>From time to time K
[
https://issues.apache.org/jira/browse/BEAM-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-2752:
--
Description:
>From time to time Kinesis IO throws ConcurrentModificationException on taking
>a c
[
https://issues.apache.org/jira/browse/BEAM-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167625#comment-16167625
]
Pawel Bartoszek commented on BEAM-2948:
---
For anybody running into similar issue befor
[
https://issues.apache.org/jira/browse/BEAM-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167625#comment-16167625
]
Pawel Bartoszek edited comment on BEAM-2948 at 9/15/17 9:39 AM:
-
Pawel Bartoszek created BEAM-3151:
-
Summary: AfterProcessingTime trigger doesn't create expected file
panes
Key: BEAM-3151
URL: https://issues.apache.org/jira/browse/BEAM-3151
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pawel Bartoszek updated BEAM-3151:
--
Description:
I am seeing some weird behaviour with Beam 2.0.0 about file panes created when
usin
Pawel Bartoszek created BEAM-3152:
-
Summary: AfterProcessingTime trigger doesn't create any file panes
Key: BEAM-3152
URL: https://issues.apache.org/jira/browse/BEAM-3152
Project: Beam
Issue
50 matches
Mail list logo
