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
Project: Beam
Issue Type: Improvement
Components: io-java-kinesis
Affects Versions: 2.2.0
Reporter: Pawel Bartoszek
Assignee: Jean-Baptiste Onofré
When the job is restored from savepoint Kinesis Reader throws sometimes
{{java.lang.IllegalArgumentException: Attempting to move backwards}}
After a few job restarts caused again by the same exception, job finally starts
up and continues to run with no further problems.
{code:java}
java.lang.IllegalArgumentException: Attempting to move backwards
at
org.apache.beam.sdk.repackaged.com.google.common.base.Preconditions.checkArgument(Preconditions.java:122)
at org.apache.beam.sdk.util.MovingFunction.flush(MovingFunction.java:97)
at org.apache.beam.sdk.util.MovingFunction.add(MovingFunction.java:114)
at org.apache.beam.sdk.io.kinesis.KinesisReader.advance(KinesisReader.java:137)
at
org.apache.beam.runners.flink.metrics.ReaderInvocationUtil.invokeAdvance(ReaderInvocationUtil.java:67)
at
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.run(UnboundedSourceWrapper.java:264)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:87)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:55)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:95)
at
org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(StoppableSourceStreamTask.java:39)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:263)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702){code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
