flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Maximilian Michels (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3701) Cant call execute after first execution
Date Tue, 19 Apr 2016 12:23:25 GMT

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

Mime
View raw message