Do you see any other errors before you get this exception? If not, try to use a different stream codec: https://github.com/apache/apex-malhar/blob/master/library/src/main/java/org/apache/apex/malhar/lib/codec/KryoSerializableStreamCodec.java
On Tue, Aug 21, 2018 at 2:12 PM Oliver Winke <oliver.wi...@gmail.com> wrote: > 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 > >
