I've created a table with nullable columns but when I use the Storage API to stream read the table, if there are rows that don't have data in all column, the avro encoding fails with value does not match its schema: long: expected: Go numeric; received: <nil>
RowToInsert.of(
mapOf(
ENCOUNTER_ID_COLUMN to 1234,
PATIENT_ID_COLUMN to 1234,
APPOINTMENT_ID_COLUMN to null,
ENCOUNTER_DATE_COLUMN to null
)
)
Throws: io.grpc.StatusRuntimeException: UNKNOWN: failed to encode binary from go value: cannot encode binary record "testproject.athena_dataviewer.encounters" field "APPOINTMENTID": value does not match its schema: long: expected: Go numeric; received: <nil>
I've created a table with nullable columns but when I use the Storage API to stream read the table, if there are rows that don't have data in all column, the avro encoding fails with
value does not match its schema: long: expected: Go numeric; received: <nil>
Example: Create Table
Insert Row:
Throws:
io.grpc.StatusRuntimeException: UNKNOWN: failed to encode binary from go value: cannot encode binary record "testproject.athena_dataviewer.encounters" field "APPOINTMENTID": value does not match its schema: long: expected: Go numeric; received: <nil>