Skip to content

Commit a07331e

Browse files
committed
Update schema nullable issue.
1 parent 8b4940e commit a07331e

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

database-commons/src/main/java/io/cdap/plugin/db/DBRecord.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,7 @@ protected void setField(ResultSet resultSet, StructuredRecord.Builder recordBuil
153153
recordBuilder.setDecimal(field.getName(), (BigDecimal) o);
154154
} else if (o instanceof BigInteger) {
155155
Schema schema = field.getSchema();
156+
schema = schema.isNullable() ? schema.getNonNullable() : schema;
156157
if (schema.getType() == Schema.Type.LONG) {
157158
recordBuilder.set(field.getName(), ((BigInteger) o).longValueExact());
158159
} else {

0 commit comments

Comments
 (0)