Thanks Stephan :)
Will try the same.
Thanks and Regards
Amit Pawar
On Thu, May 28, 2015 at 10:41 AM, Stephan Ewen wrote:
> Hi!
>
> If you want to have type hierarchies (like base tuples and different
> classes), you cannot use tuples (they are expected to be 'exact schema
elements to be of same type).
Is there any workaround? Or using fromCollection is the only option?
Thanks for your help in advance.
Thanks and Regards
Amit Pawar
org.apache.flink.api.java.operators.JoinOperator;
JavaPlan, too, in turn gives us the List of Common API operators.
Thanks for your help.
Thanks and Regards
Amit Pawar
On Mon, Apr 27, 2015 at 3:18 PM, Stephan Ewen wrote:
> Hi!
>
> It seems you are actually working on the Optimizer's representation of the
> program. The o
());
}
For a given DAG connection, we can determine source and target, also in
terms of Operator.
Is it possible to determine on which dataset is the operator working on?
Thanks and Regards
Amit Pawar
On Thu, Apr 23, 2015 at 3:01 PM, Stephan Ewen wrote:
> Okay, nice to hear!
>
> Ping us if you
Thanks Stephan.
Using flink-dist jar solves the issue.
Thanks and Regards
Amit Pawar
On Thu, Apr 23, 2015 at 2:02 PM, Stephan Ewen wrote:
> Hi!
>
> What you describe sounds pretty much like a version mixup - NoSuchMethod
> indicates one part of the code is out of sync with the ot
.getPostPassFromPlan(Optimizer.java:557)
... 2 more
I can work around that by having the necessary flink projects in
eclipse/build path, but then I face different issue of scala, No such
method exception on env.execute();
Please advise.
Thanks and Regards
Amit Pawar
On Mon, Mar 30, 2015 at 6:26 PM,
ents field points to the
line of code in the class, which is not that helpful)
If not, is it possible (by some other way) to get the above details just by
using the Flink job/jar as an input?
Thanks and Regards
Amit Pawar
