Hello again,
I also like to show the Strack-Tracks. It points to the
env.execute(A3NameWithBoss.class.toString());:
eu.stratosphere.client.program.ProgramInvocationException: The main
method caused an error.
at
eu.stratosphere.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:399)
at
eu.stratosphere.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:302)
at eu.stratosphere.client.program.Client.run(Client.java:246)
at
eu.stratosphere.client.CliFrontend.executeProgram(CliFrontend.java:327)
at eu.stratosphere.client.CliFrontend.run(CliFrontend.java:314)
at
eu.stratosphere.client.CliFrontend.parseParameters(CliFrontend.java:927)
at eu.stratosphere.client.CliFrontend.main(CliFrontend.java:951)
Caused by: eu.stratosphere.compiler.CompilerException: Error translating
node 'Union "Union" : UNION [[ GlobalProperties
[partitioning=HASH_PARTITIONED, on fields [2]] ]] [[ LocalProperties
[ordering=null, grouped=null, unique=null] ]]': null
at
eu.stratosphere.compiler.plantranslate.NepheleJobGraphGenerator.preVisit(NepheleJobGraphGenerator.java:355)
at
eu.stratosphere.compiler.plantranslate.NepheleJobGraphGenerator.preVisit(NepheleJobGraphGenerator.java:99)
at
eu.stratosphere.compiler.plan.DualInputPlanNode.accept(DualInputPlanNode.java:157)
at
eu.stratosphere.compiler.plan.DualInputPlanNode.accept(DualInputPlanNode.java:159)
at
eu.stratosphere.compiler.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:141)
at
eu.stratosphere.compiler.plan.OptimizedPlan.accept(OptimizedPlan.java:159)
at
eu.stratosphere.compiler.plantranslate.NepheleJobGraphGenerator.compileJobGraph(NepheleJobGraphGenerator.java:169)
at
eu.stratosphere.client.program.Client.getJobGraph(Client.java:222)
at eu.stratosphere.client.program.Client.run(Client.java:293)
at eu.stratosphere.client.program.Client.run(Client.java:288)
at
eu.stratosphere.client.program.ContextEnvironment.execute(ContextEnvironment.java:50)
at
de.hshannover.vis.flink.jobdb.A3NameWithBoss.main(A3NameWithBoss.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
eu.stratosphere.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:384)
... 6 more
Caused by: java.lang.NullPointerException
at
eu.stratosphere.pact.runtime.task.util.TaskConfig.setDriver(TaskConfig.java:291)
at
eu.stratosphere.compiler.plantranslate.NepheleJobGraphGenerator.createDualInputVertex(NepheleJobGraphGenerator.java:812)
at
eu.stratosphere.compiler.plantranslate.NepheleJobGraphGenerator.preVisit(NepheleJobGraphGenerator.java:303)
... 22 more
On 17.08.2014 18:48, Alexander Sirotin wrote:
Hello everybody,
I am reading a text-file and like to outer-join it with another
text-file. Because I do not know, how to call an outer-join throw
Flink, I am adding a dummy-row "-1" via union to one of these Dataset:
DataSet<Tuple3<String, Integer, Integer>> myNull = env
.fromElements(new Tuple3<String, Integer, Integer>("-1",
new Integer(-1), new Integer(-1)));
names = names.union(myNull);
But if I look to the results, I never can see this value or the values
from the other datasets, who should be joined with it.
Thank you very much. I hope someone knows how I can solve this problem.
Best regards,
Alex
