ue) => try{value.compareTo(o.asInstanceOf[GString].v)}
> catch { case e : Throwable => 0 }
> case GNull() => 0
> case _ => 0
> }
> }
> }
>
>
>
>
>
> *-Abdulrahman
> Kaitoua---
ue) => try{value.compareTo(o.asInstanceOf[GString].v)}
catch { case e : Throwable => 0 }
case GNull() => 0
case _ => 0
}
}
}
-
Abdulrahman Kaitoua
--------
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 client
> (./bin/flink)
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 com.dataarti
