Hello, I am using an implementation of AbstractHttpGetOperator. Without partitioning the operator seems to work. When using a stateless partitioner I am getting the following error:
2018-08-21 20:53:42,762 ERROR com.datatorrent.stram.codec.DefaultStatefulStreamCodec: Catastrophic Error: Execution halted due to Kryo exception! com.esotericsoftware.kryo.KryoException: Encountered unregistered class ID: 12 at com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:119) at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641) at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752) at com.datatorrent.stram.codec.DefaultStatefulStreamCodec.fromDataStatePair(DefaultStatefulStreamCodec.java:98) at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:391) at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:339) at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:269) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1477) Any idea what this could be about? Thanks, Oliver