Skip to content

Commit b2b24c0

Browse files
authored
Merge pull request #257 from data-integrations/PLUGIN-1156
[PLUGIN-1156] Update schema nullable issue.
2 parents 8b4940e + a07331e commit b2b24c0

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)