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 supports
also Scala-style POJOs. You just have to make sure that your class
contains a default constructor.
This is a valid POJO:
class SomeClass(var prop: Int) {
def this() = this(0)
}
I hope that helps.
Timo
Am 15/02/17 um 10:48 schrieb Chesnay Schepler:
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 PR.
Regards,
Chesnay
On 15.02.2017 10:08, Adarsh Jain wrote:
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>:
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>
