Skip to content

Commit ec11ba7

Browse files
committed
fix snowflake QPT return empty result
1 parent d88b5a3 commit ec11ba7

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

athena-snowflake/src/main/java/com/amazonaws/athena/connectors/snowflake/SnowflakeMetadataHandler.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -230,6 +230,9 @@ public GetDataSourceCapabilitiesResponse doGetDataSourceCapabilities(BlockAlloca
230230
@Override
231231
public void enhancePartitionSchema(SchemaBuilder partitionSchemaBuilder, GetTableLayoutRequest request)
232232
{
233+
if (request.getConstraints().isQueryPassThrough()) {
234+
return;
235+
}
233236
LOGGER.info("{}: Catalog {}, table {}", request.getQueryId(), request.getTableName().getSchemaName(), request.getTableName());
234237
// Always ensure the partition column exists in the schema
235238
if (partitionSchemaBuilder.getField(BLOCK_PARTITION_COLUMN_NAME) == null) {

0 commit comments

Comments
 (0)