arya created FLINK-25294: ---------------------------- Summary: Incorrect cloudpickle import Key: FLINK-25294 URL: https://issues.apache.org/jira/browse/FLINK-25294 Project: Flink Issue Type: Bug Components: API / Python Affects Versions: 1.14.0 Reporter: arya
In flink-python/pyflink/fn_execution/coder_impl_fast.pyx line 30 {code:python} from cloudpickle import cloudpickle {code} should simply be {code:python} import cloudpickle{code} or else I get AttributeError: module 'cloudpickle.cloudpickle' has no attribute 'dumps' when using keyed states I assume this is left over from when cloudpickle was incorrectly packaged, then fixed in [FLINK-14556|https://issues.apache.org/jira/browse/FLINK-14556], so this might have been a problem since 1.10.0 -- This message was sent by Atlassian Jira (v8.20.1#820001)