Hi Ovidiu, which version of Flink are you using?
Cheers, Till On Thu, Oct 20, 2016 at 6:38 PM, Ovidiu Cristian Marcu < ovidiu.cristian.ma...@huawei.com> wrote: > Could you check the following issue on master? > > When running this example org.apache.flink.streaming.examples.windowing. > TopSpeedWindowing > With default configuration I have no errors. > > When I change the state backend with RocksDB I receive this error: > > java.lang.RuntimeException: Could not forward element to next operator > at org.apache.flink.streaming.runtime.tasks.OperatorChain$ > CopyingChainingOutput.collect(OperatorChain.java:388) > at org.apache.flink.streaming.runtime.tasks.OperatorChain$ > ChainingOutput.collect(OperatorChain.java:1) > at org.apache.flink.streaming.api.operators. > AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java: > 393) > at org.apache.flink.streaming.api.operators. > AbstractStreamOperator$CountingOutput.collect( > AbstractStreamOperator.java:1) > at org.apache.flink.streaming.api.operators. > TimestampedCollector.collect(TimestampedCollector.java:51) > at org.apache.flink.streaming.api.functions.windowing. > PassThroughWindowFunction.apply(PassThroughWindowFunction.java:32) > at org.apache.flink.streaming.api.functions.windowing. > ReduceApplyWindowFunction.apply(ReduceApplyWindowFunction.java:56) > at org.apache.flink.streaming.runtime.operators.windowing. > functions.InternalIterableWindowFunction.apply( > InternalIterableWindowFunction.java:50) > at org.apache.flink.streaming.runtime.operators.windowing. > functions.InternalIterableWindowFunction.apply( > InternalIterableWindowFunction.java:1) > at org.apache.flink.streaming.runtime.operators.windowing. > EvictingWindowOperator.fire(EvictingWindowOperator.java:334) > at org.apache.flink.streaming.runtime.operators.windowing. > EvictingWindowOperator.processElement(EvictingWindowOperator.java:199) > at org.apache.flink.streaming.runtime.io. > StreamInputProcessor.processInput(StreamInputProcessor.java:177) > at org.apache.flink.streaming.runtime.tasks. > OneInputStreamTask.run(OneInputStreamTask.java:66) > at org.apache.flink.streaming.runtime.tasks.StreamTask. > invoke(StreamTask.java:270) > at org.apache.flink.runtime.taskmanager.Task.run(Task. > java:609) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.NullPointerException > at org.apache.flink.api.java.typeutils.runtime. > TupleSerializer.copy(TupleSerializer.java:103) > at org.apache.flink.api.java.typeutils.runtime. > TupleSerializer.copy(TupleSerializer.java:30) > at org.apache.flink.streaming.runtime.tasks.OperatorChain$ > CopyingChainingOutput.collect(OperatorChain.java:383) > ... 15 more >
