flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <u.cel...@fu-berlin.de>
Subject Re: Problem with groupBy over custom types
Date Wed, 30 Jul 2014 22:53:12 GMT
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 <sewen@apache.org> 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?
Mime
View raw message