Thanks Timo, removing `@BeanProperty` is giving no getters, no setters
error
On Wed, Feb 15, 2017 at 3:45 PM, Timo Walther wrote:
> Forget what I said about omitting `var`, this would remove the field from
> the POJO. I opened a PR for fixing the issue: https://github.com/apache/
> flink/pu
Forget what I said about omitting `var`, this would remove the field
from the POJO. I opened a PR for fixing the issue:
https://github.com/apache/flink/pull/3318
As a workaround: If you just want to have a POJO for the Cassandra Sink
you don't need to add the `@BeanProperty` annotation. Flink
Hello,
There is an open PR about adding support for case classes to the
cassandra sinks: https://github.com/apache/flink/pull/2633
You would have to checkout the branch and build it yourself. If this
works for you it would be great if you could also give some
feedback either here or in the P
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 poss
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 wrote:
> Hi Adarsh,
>
> I think this is th
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 :
> Any help will be highly appreciable, am stuck on this one.
Any help will be highly appreciable, am stuck on this one.
On Tue, Feb 14, 2017 at 10:47 PM, Nico Kruber
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 Feb
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.
>
>
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
