You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The Cassandra sink asks the target table to have exactly the same set of columns as Sink. This is not consistent with other sinks: generally, the sink’s definition just need to be a subset of target table.
if (columnDescs.size() != cassandraColumnDescMap.size()) {
throwStatus.FAILED_PRECONDITION
.withDescription("Don't match in the number of columns in the table")
.asRuntimeException();
}
Error message/log
ERROR: Failed to run the query
Caused by these errors (recent errors listed first):
1: gRPC request to meta service failed: Internal error
2: failed to validate sink
3: sink cannot pass validation: FAILED_PRECONDITION: Don't match in the number of columns in the table
To Reproduce
No response
Expected behavior
No response
How did you deploy RisingWave?
No response
The version of RisingWave
No response
Additional context
No response
The text was updated successfully, but these errors were encountered:
Describe the bug
The Cassandra sink asks the target table to have exactly the same set of columns as Sink. This is not consistent with other sinks: generally, the sink’s definition just need to be a subset of target table.
risingwave/java/connector-node/risingwave-sink-cassandra/src/main/java/com/risingwave/connector/CassandraUtil.java
Lines 82 to 86 in f6892e9
Error message/log
To Reproduce
No response
Expected behavior
No response
How did you deploy RisingWave?
No response
The version of RisingWave
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: