Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3CAC411174 for ; Wed, 30 Jul 2014 22:53:47 +0000 (UTC) Received: (qmail 89300 invoked by uid 500); 30 Jul 2014 22:53:47 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 89252 invoked by uid 500); 30 Jul 2014 22:53:47 -0000 Mailing-List: contact dev-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list dev@flink.incubator.apache.org Received: (qmail 89241 invoked by uid 99); 30 Jul 2014 22:53:46 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jul 2014 22:53:46 +0000 X-ASF-Spam-Status: No, hits=-2.3 required=5.0 tests=RCVD_IN_DNSWL_MED,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of u.celebi@fu-berlin.de designates 130.133.4.66 as permitted sender) Received: from [130.133.4.66] (HELO outpost1.zedat.fu-berlin.de) (130.133.4.66) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jul 2014 22:53:42 +0000 Received: from inpost2.zedat.fu-berlin.de ([130.133.4.69]) by outpost.zedat.fu-berlin.de (Exim 4.82) with esmtp (envelope-from ) id <1XCckE-002lx9-A0>; Thu, 31 Jul 2014 00:53:14 +0200 Received: from dslb-088-073-112-020.088.073.pools.vodafone-ip.de ([88.73.112.20] helo=[10.0.1.52]) by inpost2.zedat.fu-berlin.de (Exim 4.82) with esmtpsa (envelope-from ) id <1XCckE-001zpy-6x>; Thu, 31 Jul 2014 00:53:14 +0200 Content-Type: text/plain; charset=us-ascii Mime-Version: 1.0 (Mac OS X Mail 7.2 \(1874\)) Subject: Re: Problem with groupBy over custom types From: Ufuk Celebi In-Reply-To: Date: Thu, 31 Jul 2014 00:53:12 +0200 Cc: fegaras@cse.uta.edu Content-Transfer-Encoding: quoted-printable Message-Id: <325ED8C5-6B2D-4266-A5CF-CF3AB4A9BEB1@fu-berlin.de> References: <53D96049.1060509@cse.uta.edu> <9CD0556A-D169-40EC-9C72-85B8D7B278DE@fu-berlin.de> <53D9662A.3070001@cse.uta.edu> To: dev@flink.incubator.apache.org X-Mailer: Apple Mail (2.1874) X-Originating-IP: 88.73.112.20 X-Virus-Checked: Checked by ClamAV on apache.org 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, = word: String]>) is no atomic key type. at = org.apache.flink.api.java.typeutils.TupleTypeInfo.createLeadingFieldCompar= ator(TupleTypeInfo.java:232) at = org.apache.flink.api.java.typeutils.TupleTypeInfo.createComparator(TupleTy= peInfo.java:124) at = org.apache.flink.compiler.postpass.JavaApiPostPass.createComparator(JavaAp= iPostPass.java:296) at = org.apache.flink.compiler.postpass.JavaApiPostPass.traverse(JavaApiPostPas= s.java:165) at = org.apache.flink.compiler.postpass.JavaApiPostPass.traverseChannel(JavaApi= PostPass.java:264) at = org.apache.flink.compiler.postpass.JavaApiPostPass.traverse(JavaApiPostPas= s.java:170) at = org.apache.flink.compiler.postpass.JavaApiPostPass.traverseChannel(JavaApi= PostPass.java:264) at = org.apache.flink.compiler.postpass.JavaApiPostPass.traverse(JavaApiPostPas= s.java:93) at = org.apache.flink.compiler.postpass.JavaApiPostPass.postPass(JavaApiPostPas= s.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:5= 8) at = org.apache.flink.example.java.wordcount.WordCountPOJO.main(WordCountPOJO.j= ava:88) On 31 Jul 2014, at 00:48, Stephan Ewen wrote: > Hi Leonidas! >=20 > What you are doing should actually be supported. Do you have more of = the > stack-trace? >=20 > 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?=