Skip to content

Commit 3739c1c

Browse files
author
gituser
committed
Merge branch 'hotfix_1.8_3.10.x_30444' into 1.8_release_4.0.x
2 parents dbe844d + e80f0f8 commit 3739c1c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flinkx-kudu/flinkx-kudu-writer/src/main/java/com/dtstack/flinkx/kudu/writer/KuduOutputFormat.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040

4141
import java.io.IOException;
4242
import java.nio.ByteBuffer;
43+
import java.sql.Date;
4344
import java.sql.Timestamp;
4445
import java.util.List;
4546

@@ -132,7 +133,7 @@ private void writeData(Row row) throws WriteRecordException {
132133
case INT32: partialRow.addInt(columnIndex, ValueUtil.getIntegerVal(val)); break;
133134
case INT64: partialRow.addLong(columnIndex, ValueUtil.getLongVal(val)); break;
134135
case UNIXTIME_MICROS:
135-
if (val instanceof Timestamp) {
136+
if (val instanceof Timestamp || val instanceof Date) {
136137
partialRow.addTimestamp(columnIndex, ValueUtil.getTimestampVal(val));
137138
} else {
138139
partialRow.addLong(columnIndex, ValueUtil.getLongVal(val));

0 commit comments

Comments
 (0)