Add catalog name to DeltaLakeTestUtils.getColumnCommentOnTrino

trinodb · Jun 6, 2023 · 44a8a7c · 44a8a7c
1 parent d2f273d
commit 44a8a7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...product-tests/src/main/java/io/trino/tests/product/deltalake/util/DeltaLakeTestUtils.java b/...product-tests/src/main/java/io/trino/tests/product/deltalake/util/DeltaLakeTestUtils.java
@@ -67,7 +67,7 @@ public static Optional<DatabricksVersion> getDatabricksRuntimeVersion()
     public static String getColumnCommentOnTrino(String schemaName, String tableName, String columnName)
     {
         return (String) onTrino()
-                .executeQuery("SELECT comment FROM information_schema.columns WHERE table_schema = '" + schemaName + "' AND table_name = '" + tableName + "' AND column_name = '" + columnName + "'")
+                .executeQuery("SELECT comment FROM delta.information_schema.columns WHERE table_schema = '" + schemaName + "' AND table_name = '" + tableName + "' AND column_name = '" + columnName + "'")
                 .getOnlyValue();
     }