Hi Pramod,

As I told we have LRUCache (LinkedHashMap of <String,String>) which needs to
be serialized and it is initialized in operator constructor. What we found
that, when operator is serialized for checkpointing the content of the this
LRUcache is not getting serialized and instead its just an empty
LinkedHashMap is serialized. We verified this by implementing the
CheckpointNotificationListener in operator and logging the state of this
cache. Note that, kryo works well with HashMap but not with LinkedHashMap
which is weird

So after looking for some other alternatives for proper serialization, we
found that default JavaSerializer does the job and hence Cache has now been
set to be serialized with JavaSerializer as below

public LRUCache<String, String> callerContextCache;

but now while verifying the operator recovery with correct state by killing
the existing apex instance and restarting it with -originalAppId, we found
that deserialization fails

As mentioned in my original post, I tried using @Map from kryo and also
changing the apa packaging to have application jar in 'lib' (since the
get-app-package-info showed the classpath to be lib/*.jar and with original
packaging assembly the application jar gets under 'app') but its still of no


View this message in context: 
Sent from the Apache Apex Users list mailing list archive at Nabble.com.

Reply via email to