Re: Serializing with Kryo NullPointerException - Java

2014-12-04 Thread Robin Keunen
version2.24.0/version /dependency fixed this On 2014-12-03 18:15, Robin Keunen wrote: Hi all, I am having troubles using Kryo and being new to this kind of serialization, I am not sure where to look. Can someone please help me? :-) Here is my custom class: public class

Serializing with Kryo NullPointerException - Java

2014-12-03 Thread Robin Keunen
(ThreadPoolExecutor.java:1145) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) java.lang.Thread.run(Thread.java:745) -- Robin Keunen Software Engineer robin.keu...@lampiris.be www.lampiris.be

Re: Type problem in Java when using flatMapValues

2014-10-03 Thread Robin Keunen
the compiler is saying too. On Thu, Oct 2, 2014 at 4:15 PM, Robin Keunen robin.keu...@lampiris.be wrote: Hi all, I successfully implemented my algorithm in Scala but my team wants it in Java. I have a problem with Generics, can anyone help me? I have a first JavaPairRDD with a structure like ((ean, key

Type problem in Java when using flatMapValues

2014-10-02 Thread Robin Keunen
value = (Double) args.get(2); int granularity = 24*60*60*1000; // 1 day return AggregationUtils.createTimeSeries(start, end, value, granularity); } } } Any idea? Thanks -- Robin Keunen Software Engineer robin.keu...@lampiris.be www.lampiris.be