diff --git a/src/main/java/com/getindata/flink/connector/jdbc/catalog/ElasticTypeMapper.java b/src/main/java/com/getindata/flink/connector/jdbc/catalog/ElasticTypeMapper.java
index bcc3020..6809aac 100644
--- a/src/main/java/com/getindata/flink/connector/jdbc/catalog/ElasticTypeMapper.java
+++ b/src/main/java/com/getindata/flink/connector/jdbc/catalog/ElasticTypeMapper.java
@@ -42,6 +42,7 @@ public class ElasticTypeMapper implements JdbcDialectTypeMapper {
     private static final String ELASTIC_SCALED_FLOAT = "SCALED_FLOAT";
     private static final String ELASTIC_SHORT = "SHORT";
     private static final String ELASTIC_GEO_POINT = "GEO_POINT";
+    private static final String ELASTIC_VERSION = "VERSION";
 
     @Override
     public DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int colIndex) throws SQLException {
@@ -53,6 +54,7 @@ public DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int co
             case ELASTIC_KEYWORD:
             case ELASTIC_IP:
             case ELASTIC_GEO_POINT:
+            case ELASTIC_VERSION:
                 return DataTypes.STRING();
             case ELASTIC_BOOLEAN:
                 return DataTypes.BOOLEAN();
diff --git a/src/test/java/com/getindata/flink/connector/jdbc/catalog/ElasticJdbcCatalogFactoryTest.java b/src/test/java/com/getindata/flink/connector/jdbc/catalog/ElasticJdbcCatalogFactoryTest.java
index 6045111..a1e9bfa 100644
--- a/src/test/java/com/getindata/flink/connector/jdbc/catalog/ElasticJdbcCatalogFactoryTest.java
+++ b/src/test/java/com/getindata/flink/connector/jdbc/catalog/ElasticJdbcCatalogFactoryTest.java
@@ -5,7 +5,7 @@
 import org.apache.flink.table.catalog.exceptions.DatabaseNotExistException;
 import org.apache.flink.table.factories.CatalogFactory.Context;
 import org.apache.flink.table.factories.FactoryUtil;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 
 import java.util.List;
 import java.util.Map;