fix

bytedance · Feb 8, 2023 · 1abcba4 · 1abcba4
1 parent 16f35a6
commit 1abcba4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...sail/connector/elasticsearch/source/reader/deserializer/ElasticsearchRowDeserializer.java b/...sail/connector/elasticsearch/source/reader/deserializer/ElasticsearchRowDeserializer.java
@@ -64,7 +64,7 @@ public Row deserialize(Map<String, Object> message) {
     Row row = new Row(this.fieldSize);
     for (int i = 0; i < this.fieldSize; i++) {
       String fieldName = this.fieldNames[i];
-      Object value = message.getOrDefault(fieldName, null);
+      Object value = message.get(fieldName);
       if (Objects.nonNull(value)) {
         TypeInfo<?> typeInfo = this.typeInfos[i];
         try {