wenjin272 commented on issue #673:
URL: https://github.com/apache/flink-agents/issues/673#issuecomment-4456828255
Hi, @avichaym, thank you for reporting this bug.
I have attempted to verify this issue locally, and the conditions under
which I reproduced it are:
1. Configure rocksdb statebackend, for hashmap state will not trigger Kryo
serialization.
2. Use flink 1.20, since flink 2.x has update Kryo to 5.x, which already
fix this issue
3. Remove the `--add-opens=java.base/java.util=ALL-UNNAMED` when start jvm.
But it will still throws another exception:
```
Caused by: java.lang.UnsupportedOperationException
at
java.base/java.util.ImmutableCollections.uoe(ImmutableCollections.java:142)
at
java.base/java.util.ImmutableCollections$AbstractImmutableCollection.add(ImmutableCollections.java:147)
at
com.esotericsoftware.kryo.serializers.CollectionSerializer.read(CollectionSerializer.java:116)
at
com.esotericsoftware.kryo.serializers.CollectionSerializer.read(CollectionSerializer.java:22)
```
I agree that we need to fix this issue to improve the user experience.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
