Re: Serialisation problem

nceOf[GDouble].v)} > catch { case e : Throwable => 0 } > case GString(value) => try{value.compareTo(o.asInstanceOf[GString].v)} > catch { case e : Throwable => 0 } > case GNull() => 0 > case _ => 0 > } > } > } > > > > > > *-Abdulrahman > Kait

RE: Serialisation problem

------- Ph.D. Candidate at Politecnico Di Milano > Subject: Re: Serialisation problem > From: aljos...@apache.org > Date: Mon, 14 Dec 2015 10:42:22 +0100 > To: user@flink.apache.org > > Hi, > the problem could be that GValue is not Comparable. Could you try making it

Re: Serialisation problem

Hi, the problem could be that GValue is not Comparable. Could you try making it extend Comparable (The Java Comparable). Cheers, Aljoscha > On 12 Dec 2015, at 20:43, Robert Metzger wrote: > > Hi, > > Can you check the log output in your IDE or the log files of the Flink

Re: Serialisation problem

Hi, Can you check the log output in your IDE or the log files of the Flink client (./bin/flink). The TypeExtractor is logging why a POJO is not recognized as a POJO. The log statements look like this: 20:42:43,465 INFO org.apache.flink.api.java.typeutils.TypeExtractor - class

Serialisation problem

Hello, I would like to hive directions to make my code work again (thanks in advance). My code used to work on versions equal or less than 9.1 but when i included 10 or 10.1 i got the following exception. This type (ObjectArrayTypeInfo) cannot be used as key I understood that it