diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java index 47c7915b2ff7..1f45a94880d5 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java @@ -4930,11 +4930,16 @@ public void testProjectionPushdownReadsLessData() getSession(), selectQuery, statsWithPushdown -> { + DataSize physicalDataSizeWithPushdown = statsWithPushdown.getPhysicalInputDataSize(); DataSize processedDataSizeWithPushdown = statsWithPushdown.getProcessedInputDataSize(); assertQueryStats( sessionWithoutPushdown, selectQuery, - statsWithoutPushdown -> assertThat(statsWithoutPushdown.getProcessedInputDataSize()).isGreaterThan(processedDataSizeWithPushdown), + statsWithoutPushdown -> { + //TODO (https://github.com/trinodb/trino/issues/17156) add dereference pushdown on the physical layer + assertThat(statsWithoutPushdown.getPhysicalInputDataSize()).isEqualTo(physicalDataSizeWithPushdown); + assertThat(statsWithoutPushdown.getProcessedInputDataSize()).isGreaterThan(processedDataSizeWithPushdown); + }, results -> assertEquals(results.getOnlyColumnAsSet(), expected)); }, results -> assertEquals(results.getOnlyColumnAsSet(), expected));