I solve mu problem very thanks
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/error-when-eun-program-left-outer-join-tp1141p1146.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
implement left outer join from two dataset Customer and Orders
using Tuple data type
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/error-when-eun-program-left-outer-join-tp1141p1143.html
Sent from the Apache Flink User Mailing List archive
ctTask.invoke(RegularPactTask.java:359)
> at
>
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:235)
> at java.lang.Thread.run(Thread.java:724)
>
> at
>
> org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:349)
> at
> org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:239)
> at
>
> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:51)
> at
>
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:540)
> at
>
> org.apache.flink.examples.java.relational.TPCHQuery3.main(TPCHQuery3.java:80)
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/error-when-eun-program-left-outer-join-tp1141.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
ExecutionEnvironment.java:540)
at
org.apache.flink.examples.java.relational.TPCHQuery3.main(TPCHQuery3.java:80)
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/error-when-eun-program-left-outer-join-tp1141.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.