Good to hear. Thanks for letting us know!
On Mon, Feb 29, 2016 at 8:14 PM, Pankaj Kumar wrote:
> yes versioning was issue . Job is working fine on flink 0.10.2.
>
> On Mon, Feb 29, 2016 at 3:15 PM, Stephan Ewen wrote:
>
>> Hi!
>>
>> A "NoSuchMethodError" is always a sign of a version mixup. Ple
yes versioning was issue . Job is working fine on flink 0.10.2.
On Mon, Feb 29, 2016 at 3:15 PM, Stephan Ewen wrote:
> Hi!
>
> A "NoSuchMethodError" is always a sign of a version mixup. Please make
> sure both versions (cluster and client) are exactly the same.
>
> Stephan
>
>
> On Sat, Feb 27,
Thanks Fabian,
I am using in both default options, since I am not testing in a cluster
yet, just local in ubuntu, I am not specifying any parallelism.
just to test I set in the program env.setParallelism(1) and running with
-p 1 (which I guess I would not need) but I am still getting the same is
Hi Marcela,
do you run the algorithm in both setups with the same parallelism?
Best, Fabian
2016-02-26 16:52 GMT+01:00 Marcela Charfuelan
:
> Hello,
>
> I implemented an algorithm that includes iterations (EM algorithm) and I
> am getting different results when running in eclipse (Luna Release
Hi Lydia,
you can use a variable outside the scope of the normal filter (the one that
you define inline, if I understand correctly), like this:
*final* int *filterParameter* = 0;
dataset.filter(new FilterFunction () {
@Override
public boolean filter(Integer value) {
return value
Hi all,
I have a DataSet and I want to apply a filter
to only get back all entries with e.g. first Integer in tuple == 0.
With a normal filter I do not have the possibility to pass an an additional
argument but I have to set that parameter inside the filter function.
Is there a possibility to
Hi!
Thanks for figuring this out.
Turns out that this issue was caused by a conflict between versions of the
Apache HTTP Components library used by the Twitter Client, and used by the
Hadoop/HDFS libraries.
>From version 1.0 on, we shade that library in Hadoop, so that issue should
be solved and
Hi!
A "NoSuchMethodError" is always a sign of a version mixup. Please make sure
both versions (cluster and client) are exactly the same.
Stephan
On Sat, Feb 27, 2016 at 11:05 AM, Pankaj Kumar wrote:
> Yes Robert ,
> i was trying to start Flink on cluster 0.10.1.
>
> But after changing flink v
Hi Zhang,
Please have a look here for the 1.0.0-rc2:
Binaries: http://people.apache.org/~rmetzger/flink-1.0.0-rc2/
Maven repository:
https://repository.apache.org/content/repositories/orgapacheflink-1064
Cheers,
Max
On Sat, Feb 27, 2016 at 4:00 AM, #ZHANG SHUHAO# wrote:
> Thanks for the confir
