liuml07 commented on code in PR #24205:
URL: https://github.com/apache/flink/pull/24205#discussion_r2191622168
##########
flink-core/src/test/java/org/apache/flink/api/java/ClosureCleanerTest.java:
##########
@@ -133,6 +135,27 @@ void testComplexTopLevelClassClean() throws Exception {
assertThat(result).isEqualTo(5);
}
+ @Test
+ public void testCleanNonSerializableNestedMap() throws Exception {
Review Comment:
There are multiple classes here in the test: `ComplexMap` has `map1` field
which is a `MapFunction`. This MapFunction refers to a non-serializable Object.
Meanwhile `ComplexMap` also has `map4` field which is a `LocalMap`. This
LocalMap also refers to same value of `map1`. So it has 4 layers of references.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
