diff --git a/chunjun-connectors/chunjun-connector-elasticsearch-base/src/main/java/com/dtstack/chunjun/connector/elasticsearch/ElasticsearchRawTypeMapper.java b/chunjun-connectors/chunjun-connector-elasticsearch-base/src/main/java/com/dtstack/chunjun/connector/elasticsearch/ElasticsearchRawTypeMapper.java
index cd905a4b20..d78edd88f4 100644
--- a/chunjun-connectors/chunjun-connector-elasticsearch-base/src/main/java/com/dtstack/chunjun/connector/elasticsearch/ElasticsearchRawTypeMapper.java
+++ b/chunjun-connectors/chunjun-connector-elasticsearch-base/src/main/java/com/dtstack/chunjun/connector/elasticsearch/ElasticsearchRawTypeMapper.java
@@ -54,9 +54,10 @@ public static DataType apply(String type) {
             case "DOUBLE":
                 return DataTypes.DOUBLE();
             case "TEXT":
-                return DataTypes.STRING();
+            case "STRING":
             case "BINARY":
-                return DataTypes.BYTES();
+            case "KEYWORD":
+                return DataTypes.STRING();
             case "DATE":
                 return DataTypes.TIMESTAMP();
             case "OBJECT":