I run the code with python3 and it works fine. However, when submitting the job to apache flink using t