sunjincheng created FLINK-14556:
-----------------------------------
Summary: Correct the package of cloud pickle
Key: FLINK-14556
URL:
https://issues.apache.org/jira/browse/FLINK-14556 Project: Flink
Issue Type: Improvement
Components: API / Python
Reporter: sunjincheng
Fix For: 1.10.0
Currently the package structure of cloud pickle is as following:
{code:java}
cloudpickle-1.2.2/
cloudpickle-1.2.2/cloudpickle/
cloudpickle-1.2.2/cloudpickle/__init__.py
cloudpickle-1.2.2/cloudpickle/cloudpickle.py
cloudpickle-1.2.2/cloudpickle/cloudpickle_fast.py
cloudpickle-1.2.2/LICENSE
{code}
It should be:
{code:java}
cloudpickle/
cloudpickle/__init__.py
cloudpickle/cloudpickle.py
cloudpickle/cloudpickle_fast.py
cloudpickle/LICENSE
{code}
Otherwise, the following error will be thrown when running in a standalone cluster :"ImportError: No module named cloudpickle".
--
This message was sent by Atlassian Jira
(v8.3.4#803005)