Hi Harshit,
According to the stack you provided, I guess you define your Python
function in the main file, and the Python function imports xgboost
globally. The reason for the error is that the xgboost library is difficult
to be serialized by cloudpickle. There are two ways to solve
1. Move `impo
Dear Team,
I am facing a issue while running pyflink program in flink cluster as it
stop running while reading the machine learning model
This is the error :
./bin/flink run --python /home/desktop/ProjectFiles/test_new.py
Job has been submitted with JobID 0a561cb330eeac5aa7b40ac047d3c