in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java [309:315]
private String extractDateFormat(String index, LogicalTypeRoot logicalType) {
String format = index.substring(index.indexOf("|") + 1, index.indexOf("}"));
if ("".equals(format)) {
format = getDefaultFormat(logicalType);
}
return format;
}