Or
apex-core/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
that is part of the core and has
https://issues.apache.org/jira/browse/APEXCORE-502
<https://issues.apache.org/jira/browse/APEXCORE-502> fixed.
Thank you,
Vlad
> On Aug 22, 2018, at 22:20, Thomas Weise <t...@apache.org> wrote:
>
> 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
>
> <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
> <mailto: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
>
