Skip to content

Commit e11c9d7

Browse files
committed
[hotfix-36382][core] 修复null无法转换为timestamp异常。
1 parent dea1375 commit e11c9d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/format/dtnest/DtNestRowDeserializationSchema.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ private Row convertTopRow() {
199199
JsonNode node = getIgnoreCase(fieldNames[i]);
200200
AbstractTableInfo.FieldExtraInfo fieldExtraInfo = fieldExtraInfos.get(i);
201201

202-
if (node == null) {
202+
if (node == null || node instanceof NullNode) {
203203
if (fieldExtraInfo != null && fieldExtraInfo.getNotNull()) {
204204
throw new IllegalStateException("Failed to find field with name '"
205205
+ fieldNames[i] + "'.");

0 commit comments

Comments
 (0)