Skip to content
New issue

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

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

Already on GitHub? Sign in to your account

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

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

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants