[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
SmedbergM updated FLINK-6866: ----------------------------- Affects Version/s: 1.3.0 Environment: Scala 2.10.6, Scala 2.11.11 Does not appear using Scala 2.12 Description: MWE: https://github.com/SmedbergM/ClosureCleanerBug MWE console output: https://gist.github.com/SmedbergM/ce969e6e8540da5b59c7dd921a496dc5 was: MWE: ``` import scala.collection.JavaConverters._ import org.apache.flink.api.java.ClosureCleaner object SerializationFailureMWE extends App { val m4j: java.util.Map[String,String] = new java.util.HashMap m4j.put("key1", "value1") val m: java.util.Map[String,String] = Map( "key1" -> "value1" ).asJava println("Cleaning native Java map") ClosureCleaner.clean(m4j, true) println("Cleaning map converted by JavaConverters") ClosureCleaner.clean(m, true) } ``` Program output: ``` Cleaning native Java map Cleaning map converted by JavaConverters Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: {key1=value1} is not serializable. The object probably contains or references non serializable fields. at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:100) at SerializationFailureMWE$delayedInit$body.apply(SerializationFailureMWE.scala:17) at scala.Function0$class.apply$mcV$sp(Function0.scala:40) at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12) at scala.App$$anonfun$main$1.apply(App.scala:71) at scala.App$$anonfun$main$1.apply(App.scala:71) at scala.collection.immutable.List.foreach(List.scala:318) at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:32) at scala.App$class.main(App.scala:71) at SerializationFailureMWE$.main(SerializationFailureMWE.scala:5) at SerializationFailureMWE.main(SerializationFailureMWE.scala) Caused by: java.io.NotSerializableException: scala.collection.convert.Wrappers$MapWrapper ... ``` > ClosureCleaner.clean fails for scala's JavaConverters wrapper classes > --------------------------------------------------------------------- > > Key: FLINK-6866 > URL: https://issues.apache.org/jira/browse/FLINK-6866 > Project: Flink > Issue Type: Bug > Components: DataStream API, Scala API > Affects Versions: 1.2.0, 1.3.0 > Environment: Scala 2.10.6, Scala 2.11.11 > Does not appear using Scala 2.12 > Reporter: SmedbergM > > MWE: https://github.com/SmedbergM/ClosureCleanerBug > MWE console output: > https://gist.github.com/SmedbergM/ce969e6e8540da5b59c7dd921a496dc5 -- This message was sent by Atlassian JIRA (v6.3.15#6346)