Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8CE9D10402 for ; Wed, 11 Feb 2015 09:09:26 +0000 (UTC) Received: (qmail 84786 invoked by uid 500); 11 Feb 2015 09:09:26 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 84720 invoked by uid 500); 11 Feb 2015 09:09:26 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 84708 invoked by uid 99); 11 Feb 2015 09:09:26 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 11 Feb 2015 09:09:26 +0000 X-ASF-Spam-Status: No, hits=2.8 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of fhueske@gmail.com designates 209.85.213.42 as permitted sender) Received: from [209.85.213.42] (HELO mail-yh0-f42.google.com) (209.85.213.42) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 11 Feb 2015 09:09:22 +0000 Received: by mail-yh0-f42.google.com with SMTP id i57so832474yha.1 for ; Wed, 11 Feb 2015 01:08:16 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=wWCbzpLVmwqLAp7aVBphKebYJ4za7mepx3pvXByDtVg=; b=j9yLXgBj96mnOW+k0ZEJ2w4rb5GAv1a62Pz/w4IWLZr2f0hWix3nrQIG0wJmjDJgVw vk5Ubu1RuEnmfS23Co/c25RCrW9m6tvxfPj1Du5ocj9jTjiWjryB+sR1OmoHlU2noo0g geZJCNbhFtyKQZ5/xIM7Lb98C0tYqmC8+iG1JEC8b5Bf65+nH4sKRwUgtGua5f5WX5NJ N8hxQ00QVqElvvbxYagmYsI8xGO+w/QndcyefBlziIksisR08/3xM8/LKSv5M57EpWXW 8SEQ+Aah0LVWthVL5PNXXTNq5Qqnx85Cpq4lI+IeEeWMtlq+Kintd/QRO+Jg3qz9Gx0s 0T7w== MIME-Version: 1.0 X-Received: by 10.170.125.10 with SMTP id r10mr670327ykb.96.1423645696637; Wed, 11 Feb 2015 01:08:16 -0800 (PST) Received: by 10.170.131.88 with HTTP; Wed, 11 Feb 2015 01:08:16 -0800 (PST) In-Reply-To: References: <1423618628097-720.post@n4.nabble.com> <1423618920510-721.post@n4.nabble.com> Date: Wed, 11 Feb 2015 10:08:16 +0100 Message-ID: Subject: Re: [Exception]Key expressions are only supported on POJO types and Tuples From: Fabian Hueske To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1139204808c063050ecc58d3 X-Virus-Checked: Checked by ClamAV on apache.org --001a1139204808c063050ecc58d3 Content-Type: text/plain; charset=UTF-8 In case you want to contribute or follow the discussion, here's the JIRA: https://issues.apache.org/jira/browse/FLINK-1511 Again, thanks for reporting! 2015-02-11 9:59 GMT+01:00 Fabian Hueske : > Hi, > > you are right, there is a problem. I reproduced the problem and it seems > that regular Scala classes are not properly analyzed and not identified as > Pojos. > As long as you only need these classes to be data holders without custom > logic, you could go with case classes. > > I will open a JIRA to extend Pojo support for regular Scala classes. > > Thanks for reporting, > Fabian > > 2015-02-11 2:42 GMT+01:00 Vinh June : > >> sorry, here is also the Metadata class that I use >> http://pastebin.com/WUQE613E >> >> >> >> -- >> View this message in context: >> http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Exception-Key-expressions-are-only-supported-on-POJO-types-and-Tuples-tp720p721.html >> Sent from the Apache Flink (Incubator) User Mailing List archive. mailing >> list archive at Nabble.com. >> > > --001a1139204808c063050ecc58d3 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
In case you want to contribute or follow the discussion, h= ere's the JIRA:=C2=A0https://issues.apache.org/jira/browse/FLINK-1511

Again, thanks for reporting!
=
2015-02-11 9:59 GMT+01:00 Fabian Hueske <fh= ueske@gmail.com>:
Hi,

you are right, there is a problem. I reprod= uced the problem and it seems that regular Scala classes are not properly a= nalyzed and not identified as Pojos.
As long as you only need the= se classes to be data holders without custom logic, you could go with case = classes.

I will open a JIRA to extend Pojo support= for regular Scala classes.

Thanks for reporting,<= /div>
Fabian

2015-02-11 2:42 GMT+01:0= 0 Vinh June <hoangthevinh.htv@gmail.com>:
sorry, here is also the Metadata class that I use<= br> http://pastebin.= com/WUQE613E



--
View this message in context: ht= tp://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com= /Exception-Key-expressions-are-only-supported-on-POJO-types-and-Tuples-tp72= 0p721.html
Sent from the Apache Flink (Incubator) User Mailing List archive.= mailing list archive at Nabble.com.


--001a1139204808c063050ecc58d3--