diff --git a/bitsail-connectors/connector-elasticsearch/src/main/java/com/bytedance/bitsail/connector/elasticsearch/source/reader/deserializer/ElasticsearchRowDeserializer.java b/bitsail-connectors/connector-elasticsearch/src/main/java/com/bytedance/bitsail/connector/elasticsearch/source/reader/deserializer/ElasticsearchRowDeserializer.java
index ad5e05514..fdc689ed9 100644
--- a/bitsail-connectors/connector-elasticsearch/src/main/java/com/bytedance/bitsail/connector/elasticsearch/source/reader/deserializer/ElasticsearchRowDeserializer.java
+++ b/bitsail-connectors/connector-elasticsearch/src/main/java/com/bytedance/bitsail/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 {