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 receiving the error below when I pass an instance of
`UUIDGenerator` to the `KeyedCoProcessFunction` and try to run the
job.
***********************************************************************************
Exception in thread "main" java.lang.UnsupportedOperationException:
Generic types have been disabled in the ExecutionConfig and type
java.util.UUID is treated as a generic type.
***********************************************************************************
At that point I wonder how can/should I do to pass an instance of
`UUIDGenerator` to `PrebetModelRequestProcessor` function.
ModelRequestProcessor Class:
========================================================
public class ModelRequestProcessor extends
KeyedCoProcessFunction<String, CustomerInformation, CustomerRisk,
ModelRequest> {
protected final UUIDGenerator uuidGenerator;
public PrebetModelRequestProcessor(UUIDGenerator generator) {
this.uuidGenerator = generator;
}
}
========================================================
UUIDGenerator Class:
========================================================
public class UUIDGenerator implements Serializable {
private static final long serialVersionUID = 42L;
public java.util.UUID generate() {
return java.util.UUID.randomUUID();
}
}
========================================================
