[
https://issues.apache.org/jira/browse/FLINK-22875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357243#comment-17357243
]
JYXL edited comment on FLINK-22875 at 6/4/21, 10:23 AM:
--------------------------------------------------------
and the result as follow:
{code:java}
before pickle object is StateTtlConfig{updateType=Disabled,
stateVisibility=NeverReturnExpired, ttlTimeCharacteristic=ProcessingTime,
ttl=9223372036854775807 ms}
before pickle object type is <class 'py4j.java_gateway.JavaObject'>
after unpickle object is {'cleanupStrategies': {'cleanupInBackground': True,
'rocksdbCompactFilterCleanupStrategy': {'__class__':
'org.apache.flink.api.common.state.StateTtlConfig$RocksdbCompactFilterCleanupStrategy',
'queryTimeAfterNumEntries': 1000}, 'incrementalCleanupStrategy':
{'cleanupSize': 5, '__class__':
'org.apache.flink.api.common.state.StateTtlConfig$IncrementalCleanupStrategy'},
'__class__':
'org.apache.flink.api.common.state.StateTtlConfig$CleanupStrategies'},
'stateVisibility': 'NeverReturnExpired', 'ttlTimeCharacteristic':
'ProcessingTime', 'ttl': {'unit': 'MILLISECONDS', 'size': 9223372036854775807,
'__class__': 'org.apache.flink.api.common.time.Time'}, '__class__':
'org.apache.flink.api.common.state.StateTtlConfig', 'enabled': False,
'updateType': 'Disabled'}
after unpickle object is <class 'py4j.java_collections.JavaMap'>
{code}
was (Author: jyxl_1):
and the result as follow:
{code:python}
before pickle object is StateTtlConfig{updateType=Disabled,
stateVisibility=NeverReturnExpired, ttlTimeCharacteristic=ProcessingTime,
ttl=9223372036854775807 ms}
before pickle object type is <class 'py4j.java_gateway.JavaObject'>
after unpickle object is {'cleanupStrategies': {'cleanupInBackground': True,
'rocksdbCompactFilterCleanupStrategy': {'__class__':
'org.apache.flink.api.common.state.StateTtlConfig$RocksdbCompactFilterCleanupStrategy',
'queryTimeAfterNumEntries': 1000}, 'incrementalCleanupStrategy':
{'cleanupSize': 5, '__class__':
'org.apache.flink.api.common.state.StateTtlConfig$IncrementalCleanupStrategy'},
'__class__':
'org.apache.flink.api.common.state.StateTtlConfig$CleanupStrategies'},
'stateVisibility': 'NeverReturnExpired', 'ttlTimeCharacteristic':
'ProcessingTime', 'ttl': {'unit': 'MILLISECONDS', 'size': 9223372036854775807,
'__class__': 'org.apache.flink.api.common.time.Time'}, '__class__':
'org.apache.flink.api.common.state.StateTtlConfig', 'enabled': False,
'updateType': 'Disabled'}
after unpickle object is <class 'py4j.java_collections.JavaMap'>
{code}
> Cannot work by Pickler and Unpickler
> ------------------------------------
>
> Key: FLINK-22875
> URL: https://issues.apache.org/jira/browse/FLINK-22875
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.13.0
> Reporter: JYXL
> Priority: Major
>
> Pickler and Unpickler get different object
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
