zhangbo 1 年之前
父節點
當前提交
1c67d364e3
共有 1 個文件被更改,包括 7 次插入1 次删除
  1. 7 1
      src/main/java/examples/dataloader/RequestContextOffline.java

+ 7 - 1
src/main/java/examples/dataloader/RequestContextOffline.java

@@ -55,7 +55,13 @@ public class RequestContextOffline extends RequestContext {
         if (!Arrays.stream(record.getColumns()).map(r-> r.getName()).collect(Collectors.toSet()).contains(key)){
             return;
         }
-        String value = record.getString(key);
+        String value;
+        try{
+            value = record.getString(key);
+        }catch (Exception e){
+            value = String.valueOf(record.getBigint(key));
+        }
+
         if (value == null){
             return;
         }