We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents c07155c + 6df54e7 commit af49180Copy full SHA for af49180
core/src/main/java/com/dtstack/flink/sql/format/dtnest/DtNestRowDeserializationSchema.java
@@ -225,7 +225,7 @@ private Row convertTopRow() {
225
JsonNode node = getIgnoreCase(fieldNames[i]);
226
AbstractTableInfo.FieldExtraInfo fieldExtraInfo = fieldExtraInfos.get(i);
227
228
- if (node == null) {
+ if (node == null || node instanceof NullNode) {
229
if (fieldExtraInfo != null && fieldExtraInfo.getNotNull()) {
230
throw new IllegalStateException("Failed to find field with name '"
231
+ fieldNames[i] + "'.");
0 commit comments