Hi, we're having trouble running statefun jobs on a shared cloudera flink
cluster due to the presence of old protobuf-java classes on the classpath,
which don't work with statefun, causing MethodNotFound exceptions.

https://issues.apache.org/jira/browse/FLINK-26537
is to allow users to disable the verification, allowing the creators of
uber jars to include a version of protobuf-java that would be compatible
with the version of statefun that they're using.

I was thinking of adding a flink setting like "
statefun.validation.parent-first-classloader.disable=true", which would
suppress the validation in StatefulFunctionsConfigValidator#
validateParentFirstClassloaderPatterns

Please let me know if I can proceed with an implementation

Reply via email to