From a07331e50b1294578187ba3622cb643ab0741b65 Mon Sep 17 00:00:00 2001
From: JiongxinYe <yjiongxin@google.com>
Date: Fri, 29 Apr 2022 10:17:23 -0700
Subject: [PATCH] Update schema nullable issue.

---
 database-commons/src/main/java/io/cdap/plugin/db/DBRecord.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/database-commons/src/main/java/io/cdap/plugin/db/DBRecord.java b/database-commons/src/main/java/io/cdap/plugin/db/DBRecord.java
index 53bb2a42d..7592a5fdf 100644
--- a/database-commons/src/main/java/io/cdap/plugin/db/DBRecord.java
+++ b/database-commons/src/main/java/io/cdap/plugin/db/DBRecord.java
@@ -153,6 +153,7 @@ protected void setField(ResultSet resultSet, StructuredRecord.Builder recordBuil
       recordBuilder.setDecimal(field.getName(), (BigDecimal) o);
     } else if (o instanceof BigInteger) {
       Schema schema = field.getSchema();
+      schema = schema.isNullable() ? schema.getNonNullable() : schema;
       if (schema.getType() == Schema.Type.LONG) {
         recordBuilder.set(field.getName(), ((BigInteger) o).longValueExact());
       } else {