From 73cacfe784aecfd4aee58ac0bf5a31e7a709d31c Mon Sep 17 00:00:00 2001 From: Yuya Ebihara Date: Tue, 18 Jul 2023 21:09:21 +0900 Subject: [PATCH] Fix broken testDeletionVectors in Delta Lake ba18e5bce8 starts allowing access of $history table even when the table has unsupported features. --- .../product/deltalake/TestDeltaLakeDatabricksDelete.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/product/deltalake/TestDeltaLakeDatabricksDelete.java b/testing/trino-product-tests/src/main/java/io/trino/tests/product/deltalake/TestDeltaLakeDatabricksDelete.java index ba98b1fac3e2..db1499d3f7ad 100644 --- a/testing/trino-product-tests/src/main/java/io/trino/tests/product/deltalake/TestDeltaLakeDatabricksDelete.java +++ b/testing/trino-product-tests/src/main/java/io/trino/tests/product/deltalake/TestDeltaLakeDatabricksDelete.java @@ -82,12 +82,12 @@ public void testDeletionVectors() assertThat(onTrino().executeQuery("SHOW TABLES FROM delta.default")) .contains(row(tableName)); + assertThat(onTrino().executeQuery("SELECT version, operation FROM delta.default.\"" + tableName + "$history\"")) + .containsOnly(row(0, "CREATE TABLE"), row(1, "WRITE"), row(2, "DELETE")); assertThat(onTrino().executeQuery("SELECT comment FROM information_schema.columns WHERE table_schema = 'default' AND table_name = '" + tableName + "'")) .hasNoRows(); assertQueryFailure(() -> onTrino().executeQuery("SELECT * FROM delta.default." + tableName)) .hasMessageMatching(".* Table .* does not exist"); - assertQueryFailure(() -> onTrino().executeQuery("SELECT * FROM delta.default.\"" + tableName + "$history\"")) - .hasMessageMatching(".* Table .* does not exist"); assertQueryFailure(() -> onTrino().executeQuery("SHOW COLUMNS FROM delta.default." + tableName)) .hasMessageMatching(".* Table .* does not exist"); assertQueryFailure(() -> onTrino().executeQuery("DESCRIBE delta.default." + tableName))