[
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)
