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 f767970cc66d..ad209f4d0152 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 @@ -443,7 +443,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("Table '%s' does not exist", temporaryTableName); + .hasMessageContaining(".%s' does not exist", temporaryTableName); } catch (AssertionError e) { remainingTemporaryTables.computeIfAbsent(queryId, ignored -> new HashSet<>()).add(temporaryTableName);