Which type serializer is being used?

[sudranga]

Hi,

I would like to find out what types are being serialized with which serializer. Is there an easy way to get this information?

We have the following situation:

We have two types T1 and T2. The input to a window process function is a Either<T1, T2>. Both T1 and T2 themselves are POJOs. We added a field F of type Boolean(the boxed type) to T2. We then restored a job from a savepoint. It was my understanding that the POJO serializer would initialize T2.F to Boolean.False. However, T2.F is null.

Thanks

Sudharsan

[David Anderson-4]

You can use TypeInformation#of(MyClass.class).createSerializer() to determine which serializer Flink will use for a given type.

Best,

David

On Wed, Feb 17, 2021 at 7:12 PM Sudharsan R <[hidden email]> wrote:

Hi,

I would like to find out what types are being serialized with which serializer. Is there an easy way to get this information?

We have the following situation:

We have two types T1 and T2. The input to a window process function is a Either<T1, T2>. Both T1 and T2 themselves are POJOs. We added a field F of type Boolean(the boxed type) to T2. We then restored a job from a savepoint. It was my understanding that the POJO serializer would initialize T2.F to Boolean.False. However, T2.F is null.

Thanks

Sudharsan