Skip to content

Commit

Permalink
Fix table names iceberg case for trino
Browse files Browse the repository at this point in the history
  • Loading branch information
insyncoss committed Aug 11, 2023
1 parent 3b13e41 commit 3dc0b05
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@
import com.netflix.metacat.common.QualifiedName;
import com.netflix.metacat.common.dto.Pageable;
import com.netflix.metacat.common.dto.Sort;
import com.netflix.metacat.common.exception.MetacatNotSupportedException;
import com.netflix.metacat.common.server.connectors.ConnectorContext;
import com.netflix.metacat.common.server.connectors.ConnectorRequestContext;
import com.netflix.metacat.common.server.connectors.ConnectorTableService;
Expand Down Expand Up @@ -380,8 +379,8 @@ public List<QualifiedName> getTableNames(
@Nullable final Integer limit) {
try {
if (!Strings.isNullOrEmpty(filter)) {
throw new MetacatNotSupportedException(
String.format("Calling Polaris getTableNames with nonempty filter %s not supported", filter));
// workaround for trino issue, hive param filters not supported on iceberg tables
log.warn(String.format("Calling Polaris getTableNames with nonempty filter %s", filter));
}
final List<String> databaseNames = name.isDatabaseDefinition() ? ImmutableList.of(name.getDatabaseName())
: polarisStoreService.getAllDatabases().stream().map(d -> d.getDbName()).collect(Collectors.toList());
Expand Down

0 comments on commit 3dc0b05

Please sign in to comment.