Hi,

It is not necessary to use a different stream codec when you have control
over the class that is causing the error. You can annotate a different
field serializer instead, using the @FieldSerializer.Bind annotation. Here
is an example:

https://github.com/apache/apex-malhar/blob/2fe2903bfe65055c7fd361a97549b6e7e12d4289/library/src/main/java/org/apache/apex/malhar/lib/window/WindowOption.java#L50

It would be good to upgrade Kryo to 4.x in apex-core master. Would you like
to create a JIRA for it? (http://apex.apache.org/contributing.html)

Thanks,
Thomas

On Wed, May 16, 2018 at 10:31 AM, Aaron Bossert <[EMAIL PROTECTED]>
wrote:
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB