diff --git a/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java b/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java index 7404db1d3ca1..a80fbb2fbf6a 100644 --- a/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java +++ b/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java @@ -437,7 +437,7 @@ protected void checkTemporaryTables(Set queryIds) String temporaryTableName = (String) temporaryTableRow.getField(0); try { assertThatThrownBy(() -> getQueryRunner().execute("SELECT 1 FROM %s WHERE 1 = 0".formatted(temporaryTableName))) - .hasMessageContaining("%s does not exist", temporaryTableName); + .hasMessageContaining("Table '%s' does not exist", temporaryTableName); } catch (AssertionError e) { remainingTemporaryTables.computeIfAbsent(queryId, ignored -> new HashSet<>()).add(temporaryTableName);