diff --git a/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/server/src/main/java/org/apache/linkis/metadata/query/server/service/impl/MetadataQueryServiceImpl.java b/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/server/src/main/java/org/apache/linkis/metadata/query/server/service/impl/MetadataQueryServiceImpl.java index 74910409c7..ff2688208f 100644 --- a/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/server/src/main/java/org/apache/linkis/metadata/query/server/service/impl/MetadataQueryServiceImpl.java +++ b/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/server/src/main/java/org/apache/linkis/metadata/query/server/service/impl/MetadataQueryServiceImpl.java @@ -624,8 +624,7 @@ public GenerateSqlInfo getFlinkSqlByDsNameAndEnvId( return new GenerateSqlInfo(); } - public GenerateSqlInfo getFlinkSqlByElasticsearch( - String table, List columns) { + public GenerateSqlInfo getFlinkSqlByElasticsearch(String table, List columns) { GenerateSqlInfo generateSqlInfo = new GenerateSqlInfo(); String flinkTableName = table.contains(".") ? table.substring(table.indexOf(".") + 1) : table; String columnStr = "*";