[jira] [Commented] (FLINK-3701) Cant call execute after first execution

["Maximilian Michels (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247644#comment-15247644 ] 

Maximilian Michels commented on FLINK-3701:
-------------------------------------------

The issue is that the serializer lists in the {{ExecutionConfig}} are set to null after they have been serialized for cluster shipping. A solution would be to simply clear those lists and not set them to null. This would reset them to their original state for further executions. Setting them to null can also cause other problems, i.e. when additional serializers are registered after the first execution. Perhaps you could also comment [~till.rohrmann] if that works.



> Cant call execute after first execution
> ---------------------------------------
>
>                 Key: FLINK-3701
>                 URL: https://issues.apache.org/jira/browse/FLINK-3701
>             Project: Flink
>          Issue Type: Bug
>          Components: Scala Shell
>            Reporter: Nikolaas Steenbergen
>            Assignee: Maximilian Michels
>
> in the scala shell, local mode, version 1.0 this works:
> {code}
> Scala-Flink> var b = env.fromElements("a","b")
> Scala-Flink> b.print
> Scala-Flink> var c = env.fromElements("c","d")
> Scala-Flink> c.print
> {code}
> in the current master (after c.print) this leads to :
> {code}
> java.lang.NullPointerException
> 	at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:1031)
> 	at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:961)
> 	at org.apache.flink.api.java.ScalaShellRemoteEnvironment.execute(ScalaShellRemoteEnvironment.java:70)
> 	at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
> 	at org.apache.flink.api.java.DataSet.collect(DataSet.java:410)
> 	at org.apache.flink.api.java.DataSet.print(DataSet.java:1605)
> 	at org.apache.flink.api.scala.DataSet.print(DataSet.scala:1615)
> 	at .<init>(<console>:56)
> 	at .<clinit>(<console>)
> 	at .<init>(<console>:7)
> 	at .<clinit>(<console>)
> 	at $print(<console>)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:497)
> 	at scala.tools.nsc.interpreter.IMain$ReadEvalPrint.call(IMain.scala:734)
> 	at scala.tools.nsc.interpreter.IMain$Request.loadAndRun(IMain.scala:983)
> 	at scala.tools.nsc.interpreter.IMain.loadAndRunReq$1(IMain.scala:573)
> 	at scala.tools.nsc.interpreter.IMain.interpret(IMain.scala:604)
> 	at scala.tools.nsc.interpreter.IMain.interpret(IMain.scala:568)
> 	at scala.tools.nsc.interpreter.ILoop.reallyInterpret$1(ILoop.scala:760)
> 	at scala.tools.nsc.interpreter.ILoop.interpretStartingWith(ILoop.scala:805)
> 	at scala.tools.nsc.interpreter.ILoop.command(ILoop.scala:717)
> 	at scala.tools.nsc.interpreter.ILoop.processLine$1(ILoop.scala:581)
> 	at scala.tools.nsc.interpreter.ILoop.innerLoop$1(ILoop.scala:588)
> 	at scala.tools.nsc.interpreter.ILoop.loop(ILoop.scala:591)
> 	at scala.tools.nsc.interpreter.ILoop$$anonfun$process$1.apply$mcZ$sp(ILoop.scala:882)
> 	at scala.tools.nsc.interpreter.ILoop$$anonfun$process$1.apply(ILoop.scala:837)
> 	at scala.tools.nsc.interpreter.ILoop$$anonfun$process$1.apply(ILoop.scala:837)
> 	at scala.tools.nsc.util.ScalaClassLoader$.savingContextLoader(ScalaClassLoader.scala:135)
> 	at scala.tools.nsc.interpreter.ILoop.process(ILoop.scala:837)
> 	at org.apache.flink.api.scala.FlinkShell$.startShell(FlinkShell.scala:199)
> 	at org.apache.flink.api.scala.FlinkShell$.main(FlinkShell.scala:127)
> 	at org.apache.flink.api.scala.FlinkShell.main(FlinkShell.scala)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)