You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/12/31 06:22:37 UTC
[flink] branch release-1.14 updated: [FLINK-25294][python] Fix cloudpickle import
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new 6525971 [FLINK-25294][python] Fix cloudpickle import
6525971 is described below
commit 6525971b4c09f6ac6e737f1fe2c646cd05810f06
Author: siavash119 <si...@users.noreply.github.com>
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