I've pushed the fix to master.
Thank you again for reporting the issue.
On Fri, May 15, 2015 at 2:59 PM, Robert Metzger wrote:
> ;) Its simply not supported, sorry.
>
> On Fri, May 15, 2015 at 2:57 PM, Flavio Pompermaier
> wrote:
>
>> Is it a bug or is it a feature? :)
>>
>> On Fri, May 15, 201
;) Its simply not supported, sorry.
On Fri, May 15, 2015 at 2:57 PM, Flavio Pompermaier
wrote:
> Is it a bug or is it a feature? :)
>
> On Fri, May 15, 2015 at 2:56 PM, Robert Metzger
> wrote:
>
>> I think distinct() is failing on "null" values because its using a reduce
>> operation internally
Is it a bug or is it a feature? :)
On Fri, May 15, 2015 at 2:56 PM, Robert Metzger wrote:
> I think distinct() is failing on "null" values because its using a reduce
> operation internally.
>
> On Fri, May 15, 2015 at 2:46 PM, Flavio Pompermaier
> wrote:
>
>> I found that the problem is caused
I think distinct() is failing on "null" values because its using a reduce
operation internally.
On Fri, May 15, 2015 at 2:46 PM, Flavio Pompermaier
wrote:
> I found that the problem is caused by a distinct() that I perform before
> printing..are null values something not managed by distinct??
>
I found that the problem is caused by a distinct() that I perform before
printing..are null values something not managed by distinct??
On Fri, May 15, 2015 at 2:38 PM, Robert Metzger wrote:
> Hi,
>
> the error means that you are grouping on a field which contains null
> values. We can not compar
Hi,
the error means that you are grouping on a field which contains null
values. We can not compare elements against null, that's why we throw the
exception.
Are you sure that you're not having any null elements inside the DataSet
you're comparing against?
I'm not 100% sure that my fix is correc
Hi Robert,
I applied your fix but still I get one error (not in the same point at
least..)
Basically what I do is:
DataSet> someDates; //this is empty in my test
DataSet> someEvents;
DataSet> res =
someEvents.coGroup(someDates).where(0).equalTo(0).with(
new myCoGroupFunction, Tuple2, Tuple4> (...
Thanks a lot Robert! Don't mention it ;)
On Fri, May 15, 2015 at 1:54 PM, Robert Metzger wrote:
> Hey,
>
> the patch is in my branch "flink2019".
> Its really good that you've found the bug. We were using the wrong kryo
> instance to create copies of generic types.
>
> Once travis validates tha
Hey,
the patch is in my branch "flink2019".
Its really good that you've found the bug. We were using the wrong kryo
instance to create copies of generic types.
Once travis validates that everything is good, I'll push it to master.
On Fri, May 15, 2015 at 12:41 PM, Flavio Pompermaier
wrote:
> S
So do you think you could release a path soon? I need it to continue my
work..otherwise if it's very simple you could send me the snippet of code
to change my local flink version ;)
Best,
Flavio
On Fri, May 15, 2015 at 11:22 AM, Robert Metzger
wrote:
> Yes ;)
>
> On Fri, May 15, 2015 at 11:10 A
Yes ;)
On Fri, May 15, 2015 at 11:10 AM, Flavio Pompermaier
wrote:
> Do you think it's comething easy to fix..?
>
> On Fri, May 15, 2015 at 10:51 AM, Robert Metzger
> wrote:
>
>> No problem ;)
>>
>> I was able to reproduce the issue and filed a JIRA for it:
>> https://issues.apache.org/jira/bro
Do you think it's comething easy to fix..?
On Fri, May 15, 2015 at 10:51 AM, Robert Metzger
wrote:
> No problem ;)
>
> I was able to reproduce the issue and filed a JIRA for it:
> https://issues.apache.org/jira/browse/FLINK-2019
>
> On Fri, May 15, 2015 at 10:36 AM, Flavio Pompermaier > wrote:
No problem ;)
I was able to reproduce the issue and filed a JIRA for it:
https://issues.apache.org/jira/browse/FLINK-2019
On Fri, May 15, 2015 at 10:36 AM, Flavio Pompermaier
wrote:
> Unfortunately it's really difficult for me to extract the code..I'm using
> joda shipped with Flink 0.9-SNAPSHO
Unfortunately it's really difficult for me to extract the code..I'm using
joda shipped with Flink 0.9-SNAPSHOT (i.e. 2.5) and before today I've never
seen this error..als o because DateTime is Serializable :)
On Fri, May 15, 2015 at 10:25 AM, Fabian Hueske wrote:
> Is there a chance that the ver
Is there a chance that the version of JodaTime changed?
2015-05-15 10:22 GMT+02:00 Robert Metzger :
> Can you share the Flink program?
> Or at least the definition of the Tuple?
>
> I'll look into this issue in a few minutes.
>
> On Fri, May 15, 2015 at 10:13 AM, Flavio Pompermaier > wrote:
>
>>
Can you share the Flink program?
Or at least the definition of the Tuple?
I'll look into this issue in a few minutes.
On Fri, May 15, 2015 at 10:13 AM, Flavio Pompermaier
wrote:
> I'm using Flink 0.9-SNAPSHOT and I've never seen this error before today
> (the job haven't changed..)
>
> On Fri,
I'm using Flink 0.9-SNAPSHOT and I've never seen this error before today
(the job haven't changed..)
On Fri, May 15, 2015 at 10:09 AM, Robert Metzger
wrote:
> Hi Flavio,
>
> which version of Flink are you using?
> If you are using 0.9 something, then this should actually work ;)
>
> On Fri, May
Hi Flavio,
which version of Flink are you using?
If you are using 0.9 something, then this should actually work ;)
On Fri, May 15, 2015 at 10:06 AM, Flavio Pompermaier
wrote:
> Hi to all,
>
> this morning I run my Flink job and I got the following exception
> serializing a DateTime Tuple..coul
Hi to all,
this morning I run my Flink job and I got the following exception
serializing a DateTime Tuple..could you help me to understand what's
happening here?
com.esotericsoftware.kryo.KryoException: Class cannot be created (missing
no-arg constructor): org.joda.time.chrono.ISOChronology
Seria
19 matches
Mail list logo
