[FLINK-17530] Fix illegal reflective access by ClosureCleaner - ASF JIRA

Attach files

Attach Screenshot

Add vote

Voters

Watch issue

Watchers

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Sub-task
Status: Open
Priority: Major
Resolution: Unresolved
Affects Version/s: 1.11.0
Fix Version/s: None
Component/s: API / DataStream
Labels:
None

Description

To reproduce:

	@Test
	public void testJava11Warning() {
		MapFunction<String, String> fun = new MapFunction<String, String>() {
			String field = "asdf";
			@Override
			public String map(String value) throws Exception {
				return value + field;
			}
		};
		ClosureCleaner.clean(fun, ExecutionConfig.ClosureCleanerLevel.RECURSIVE, false);
	}

Causes:

WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/Users/robert/Projects/flink/flink-core/target/classes/) to field java.lang.String.value
	at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:104)
	at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
	at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:71)
	at org.apache.flink.api.java.ClosureCleanerTest.testJava11Warning(ClosureCleanerTest.java:58)