Sorry for not finishing the last - 4th - question
4) When Kyro fallback is enabled, that means fallback is the last
resort if the object can be serialized with any other serializer like
`PojoSerializer`?
Can we still benefit from the performance of Flink built-in serializer
without sacrifying the
Hi Yoel,
Thank you for answering my question, really appreciated. However, that
brings my mind more questions.
1) As far as I understood from the Flink built-in serialization, if a
class is a POJO type wrt the items defined in POJOs section here [1],
if an object is an instance of a POJO type cla
Hi Deniz,
You could declare UUIDGenerator as a transient field and instanciate it in
the open
function
Ot if you want to inject any UUIDGenerator you could provide a supplier of
UUIDGenerator that should implement Serializable and invoke it in the open
function.
On Tue, Feb 1, 2022, 10:01 PM
Hi All,
We have a function extending `KeyedCoProcessFunction` and within that
function implementation. I wanted to keep a class object as a field
which is simply responsible for generating a UUID.
We disabled Kyro fallback for generic types via
`env.getConfig().disableGenericTypes()`.
I am receiv
