Hi Oleksii,
it also can be related to the problem, that you have two different
classloaders, because Flink creates a separate classloader for every running
pipeline.
It is especially related when you run the pipeline in Session Mode.
Not sure whether it helps or not, but you can try the next con
Hi Oleksii.
The core error is (as you have seen): Caused by: java.lang.ClassCastException:
pemja.core.object.PyIterator cannot be cast to pemja.core.object.PyIterator
Now, since the name of the class is the same, the only way a cast can fail is
if the versions of that class are different. How i
