Re: State key serializer has not been configured in the config.

2016-06-24 Thread Maximilian Michels
mFlatMap.open(CoStreamFlatMap.java:49) >> at >> org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:317) >> at >> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:21

Re: State key serializer has not been configured in the config.

2016-06-23 Thread Chesnay Schepler
nk.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:215) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.Exception: State key serializer has not been configured in the config. This op

Re: State key serializer has not been configured in the config.

2016-06-23 Thread Till Rohrmann
; org.apache.flink.streaming.api.operators.co.CoStreamFlatMap.open(CoStreamFlatMap.java:49) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:317) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:215) > at org.apach

State key serializer has not been configured in the config.

2016-06-22 Thread Jacob Bay Larsen
ing.runtime.tasks.StreamTask.invoke(StreamTask.java:215) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.Exception: State key serializer has not been configured in the config. This operati