Search code examples
hazelcast

Hazelcast new compact-serialization is not working with Hazelcast Jet Pipeline

I have tested Compact serialization is working well with Hazelcast Version 5.0.2 but when I try to use it with Jet Pipeline job then getting below error of serialization.

Exception in thread "main" java.util.concurrent.CompletionException: com.hazelcast.jet.JetException: Exception in ProcessorTasklet{tb-batch-compact/mapSink(mymap1)#0}: com.hazelcast.nio.serialization.HazelcastSerializationException: Failed to serialize 'MyClass' at java.util.concurrent.CompletableFuture.reportJoin(CompletableFuture.java:375) at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934) at com.hazelcast.jet.Job.join(Job.java:78) at HzCompactBatch.main(HzCompactBatch.java:57)

Solution

  • I have tested my application with Hazelcast 5.1 BETA version with updating pom.xml file to use Hazelcast 5.1 beta dependency and seems to be working my sample application with compact serialization.

    I am posting this answer as it may be helpful to someone else.