in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java [216:229]
static {
// time related types
supportedTypes.add(LogicalTypeRoot.DATE);
supportedTypes.add(LogicalTypeRoot.TIME_WITHOUT_TIME_ZONE);
supportedTypes.add(LogicalTypeRoot.TIMESTAMP_WITHOUT_TIME_ZONE);
supportedTypes.add(LogicalTypeRoot.TIMESTAMP_WITH_TIME_ZONE);
supportedTypes.add(LogicalTypeRoot.TIMESTAMP_WITH_LOCAL_TIME_ZONE);
// general types
supportedTypes.add(LogicalTypeRoot.VARCHAR);
supportedTypes.add(LogicalTypeRoot.CHAR);
supportedTypes.add(LogicalTypeRoot.TINYINT);
supportedTypes.add(LogicalTypeRoot.INTEGER);
supportedTypes.add(LogicalTypeRoot.BIGINT);
}