I have a running pipe with Window State in a class say

Class A{
     long a;
}

It uses the default KryoSerializer

I want to add a field to

Class A {
  long a;
  long b;
}

I need to suspend with SP and resume with the new version of Class A


Is there a definite way to do this. I tried

Class A {
  long a;
   @FieldSerializer.Optional("0")
  long b;
}

but that seems to default to 0 , even when the Aggregation is putting in
values.

Could somebody give pointers as to how to solve this

Thanks a ton.

Reply via email to