Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

#

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Jump to bottom

CassandraSinkTask throws an Exception if the SinkRecord has a field of STRUCT type #17

Open
aaruna opened this issue Apr 11, 2016 · 1 comment
Open

CassandraSinkTask throws an Exception if the SinkRecord has a field of STRUCT type #17

aaruna opened this issue Apr 11, 2016 · 1 comment
Labels
bug
Milestone
1.0

Comments

@aaruna
Copy link
Contributor

aaruna commented Apr 11, 2016

No description provided.

@helena helena added the bug label Apr 21, 2016
@helena helena modified the milestone: 1.0 May 3, 2016
@aaruna
Copy link
Contributor Author

aaruna commented May 3, 2016

This is partly fixed by #18
So when cassandra.sink.field.mapping is set, then there is no Exception thrown.
However, if that property is not set, we assume that there is a one-to-one mapping from Fields to the Columns, so we get an error if there is a field of STRUCT type.
We can avoid this by ignoring unsupported CQL types, rather than trying to stringify the field value and using the same in INSERT statement.

# for free to join this conversation on GitHub. Already have an account? # to comment
Assignees
No one assigned
Labels
bug
Projects
None yet
Milestone
1.0
Development

No branches or pull requests
2 participants
@helena @aaruna