Skip to content

Commit e80f0f8

Browse files
committed
hotfix:【解决kuduWriter date转long报错】【30444】
1 parent bd0c5f3 commit e80f0f8

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)