We are facing an issue while loading data from json file into cassandra cluster. Here is the command:
dsbulk-1.4.1/bin/dsbulk load -url ex1.json -h 'x.x.x.x,x.x.x.x,x.x.x.x' -k xxxxxx -t users -u xxxxx -p xxxxxx --driver.advanced.auth-provider.class PlainTextAuthProvider
ex1.json:
{
"uidx": "123456"
}
users table:
CREATE TABLE users (uidx text PRIMARY KEY);
From mapping-errors.log Resource: file:/home/deploy/ex1.json Position: 1 Source: "uidx": "123456"\u000a com.datastax.dsbulk.engine.internal.schema.InvalidMappingException: Required field uidx (mapped to column uidx) was missing from record. Please remove it from the mapping or set schema.allowMissingFields to true. at com.datastax.dsbulk.engine.internal.schema.InvalidMappingException.missingField(InvalidMappingException.java:38) at com.datastax.dsbulk.engine.internal.schema.DefaultRecordMapper.ensureAllFieldsPresent(DefaultRecordMapper.java:185) at com.datastax.dsbulk.engine.internal.schema.DefaultRecordMapper.map(DefaultRecordMapper.java:106) at java.lang.Thread.run(Thread.java:748) [22 skipped] Resource: file:/home/deploy/ex1.json Position: 2 Source: }\u000a com.datastax.dsbulk.engine.internal.schema.InvalidMappingException: Required field uidx (mapped to column uidx) was missing from record. Please remove it from the mapping or set schema.allowMissingFields to true. at com.datastax.dsbulk.engine.internal.schema.InvalidMappingException.missingField(InvalidMappingException.java:38) at com.datastax.dsbulk.engine.internal.schema.DefaultRecordMapper.ensureAllFieldsPresent(DefaultRecordMapper.java:185) at com.datastax.dsbulk.engine.internal.schema.DefaultRecordMapper.map(DefaultRecordMapper.java:106) at java.lang.Thread.run(Thread.java:748) [22 skipped]
Can you please let us know what are we doing incorrectly here?
Thanks !