[
https://issues.apache.org/jira/browse/FLINK-22875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357231#comment-17357231
]
JYXL commented on FLINK-22875:
------------------------------
I'm using py4j loading Pickler and Unpickler, and pickle a java object by
Pickler.dumps, then I unpickle it by Unpickler.loads. However, the final result
is different from beginning.
code as follow:
{code:python}
# pickle java object
def pickle_j_object(self):
gateway = get_gateway()
JPickler =
gateway.jvm.org.apache.flink.api.python.shaded.net.razorvine.pickle.Pickler
j_pickler = JPickler()
return bytearray(j_pickler.dumps(self.j_object))
@classmethod
def unpickle_j_object(cls, value: bytearray):
gateway = get_gateway()
JUnpickler =
gateway.jvm.org.apache.flink.api.python.shaded.net.razorvine.pickle.Unpickler
j_unpickler = JUnpickler()
return j_unpickler.loads(value)
{code}
> Cannot work by Pickler and Unpickler
> ------------------------------------
>
> Key: FLINK-22875
> URL: https://issues.apache.org/jira/browse/FLINK-22875
> Project: Flink
> Issue Type: Bug
> Reporter: JYXL
> Priority: Major
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
