This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 36d3416 [FLINK-25294][python] Fix cloudpickle import
36d3416 is described below
commit 36d341691fdfdae0c8df7acfd2cc9269cb5f2b59
Author: siavash119 <[email protected]>
AuthorDate: Tue Dec 14 15:28:27 2021 +0800
[FLINK-25294][python] Fix cloudpickle import
This closes #18099.
---
flink-python/pyflink/fn_execution/coder_impl_fast.pyx | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-python/pyflink/fn_execution/coder_impl_fast.pyx
b/flink-python/pyflink/fn_execution/coder_impl_fast.pyx
index f66985d..c99ff5c 100644
--- a/flink-python/pyflink/fn_execution/coder_impl_fast.pyx
+++ b/flink-python/pyflink/fn_execution/coder_impl_fast.pyx
@@ -27,7 +27,7 @@ import decimal
import pickle
from typing import List, Union
-from cloudpickle import cloudpickle
+import cloudpickle
import pyarrow as pa
from pyflink.common import Row, RowKind
