I got the following exception when trying something along those lines as
Leonidas:
Exception in thread "main" java.lang.IllegalArgumentException: The field at
position 0 (PojoType<org.apache.flink.example.java.wordcount.WordCountPOJO.WC,
fields = [count: Integer, other:
GenericType<org.apache.flink.example.java.wordcount.WordCountPOJO.WC>, word:
String]>) is no atomic key type.
at
org.apache.flink.api.java.typeutils.TupleTypeInfo.createLeadingFieldComparator(TupleTypeInfo.java:232)
at
org.apache.flink.api.java.typeutils.TupleTypeInfo.createComparator(TupleTypeInfo.java:124)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.createComparator(JavaApiPostPass.java:296)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.traverse(JavaApiPostPass.java:165)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.traverseChannel(JavaApiPostPass.java:264)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.traverse(JavaApiPostPass.java:170)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.traverseChannel(JavaApiPostPass.java:264)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.traverse(JavaApiPostPass.java:93)
at
org.apache.flink.compiler.postpass.JavaApiPostPass.postPass(JavaApiPostPass.java:77)
at org.apache.flink.compiler.PactCompiler.compile(PactCompiler.java:584)
at org.apache.flink.compiler.PactCompiler.compile(PactCompiler.java:461)
at
org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:239)
at
org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:58)
at
org.apache.flink.example.java.wordcount.WordCountPOJO.main(WordCountPOJO.java:88)
On 31 Jul 2014, at 00:48, Stephan Ewen <[email protected]> wrote:
> Hi Leonidas!
>
> What you are doing should actually be supported. Do you have more of the
> stack-trace?
>
> It seems that there is some non-serializable part somewhere in the
> GenericTypeComparator..
Shouldn't FData be of PojoType and not GenericType in Leonidas example and
hence suffer from the same problem as I did?
