Minor fix for KryoValueEncoder
@@ -47,10 +47,10 @@ public class KryoValueEncoder extends AbstractValueEncoder {
kryoAndOutput[1] = new WeakReference<>(output);
}
+ try {
if (useIdentityNumber) {
output.writeInt(IDENTITY_NUMBER);
}
- try {
kryo.writeClassAndObject(output, value);
return output.toBytes();
} finally {
