Hi Adarsh,
I looked into your issue. The problem is that `var` generates
Scala-style getters/setters and the annotation generates Java-style
getters/setters. Right now Flink only supports one style in a POJO, I
don't know why we have this restriction. I will work on a fix for that.
Is it possible for you to remove the `var`? According to this
Stackoverflow it is also considered a bad practice:
http://stackoverflow.com/questions/35038977/is-it-good-practice-to-use-beanproperty-in-scala-instead-of-defining-getter-set
Regards,
Timo
Am 15/02/17 um 10:08 schrieb Adarsh Jain:
Thanks Fabian, I need to sink data in Cassandra and direct sink with
case class is not available (correct me if I am wrong)
If we use Tuple then we are restricted to 22 fields
What do you suggest here?
On Wed, Feb 15, 2017 at 2:32 PM, Fabian Hueske <fhue...@gmail.com
<mailto:fhue...@gmail.com>> wrote:
Hi Adarsh,
I think this is the same bug. I'm afraid you have to wait until
the problem is fixed.
The only workaround would be to use a different data type, for
example a case class.
Best, Fabian
2017-02-15 6:08 GMT+01:00 Adarsh Jain <eradarshj...@gmail.com
<mailto:eradarshj...@gmail.com>>:
Any help will be highly appreciable, am stuck on this one.
On Tue, Feb 14, 2017 at 10:47 PM, Nico Kruber
<n...@data-artisans.com <mailto:n...@data-artisans.com>> wrote:
Hi Adarsh,
thanks for reporting this. It should be fixed eventually.
@Timo: do you have an idea for a work-around or quick-fix?
Regards
Nico
On Tuesday, 14 February 2017 21:11:21 CET Adarsh Jain wrote:
> I am getting the same problem when trying to do FlatMap
operation on my
> POJO class.
>
> Exception in thread "main"
java.lang.IllegalStateException: Detected
> more than one setter
>
>
>
> Am using Flink 1.2, the exception is coming when using
FlatMap
>
> https://issues.apache.org/jira/browse/FLINK-5070
<https://issues.apache.org/jira/browse/FLINK-5070>
