Re: Facing Issue in running Python Flink Program in flink cluster (Version=1.15.2)

2022-11-21 Thread Xingbo Huang
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

Facing Issue in running Python Flink Program in flink cluster (Version=1.15.2)

2022-11-21 Thread harshit.varsh...@iktara.ai
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