[bugfix][lib][storage] Fix dateFormat is invalid when data type is ti…

…mestamp Fix #984
wgzhao · Dec 13, 2023 · 7844518 · 7844518
1 parent d165f76
commit 7844518
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/addax-storage/src/main/java/com/wgzhao/addax/storage/writer/StorageWriterUtil.java b/lib/addax-storage/src/main/java/com/wgzhao/addax/storage/writer/StorageWriterUtil.java
@@ -29,6 +29,7 @@
 import com.wgzhao.addax.common.element.DateColumn;
 import com.wgzhao.addax.common.element.LongColumn;
 import com.wgzhao.addax.common.element.Record;
+import com.wgzhao.addax.common.element.TimestampColumn;
 import com.wgzhao.addax.common.exception.AddaxException;
 import com.wgzhao.addax.common.plugin.RecordReceiver;
 import com.wgzhao.addax.common.plugin.TaskPluginCollector;
@@ -309,7 +310,7 @@ public static List<String> recordToList(Record record, String nullFormat, DateFo
                         splitRows.add(nullFormat);
                     } else {
                         // warn: it's all ok if nullFormat is null
-                        boolean isDateColumn = column instanceof DateColumn;
+                        boolean isDateColumn = column instanceof DateColumn || column instanceof TimestampColumn;
                         if (!isDateColumn) {
                             splitRows.add(column.asString());
                         } else {