This is an automated email from the ASF dual-hosted git repository. diqiu50 pushed a commit to branch fix/flaky-catalog-status-failure-count in repository https://gitbox.apache.org/repos/asf/gravitino.git
commit cf7a5c5ca0f2b0d758b35d0279260377ce01b2a9 Author: yuhui <[email protected]> AuthorDate: Thu Sep 17 21:15:36 2026 +0800 [#13286] test(trino-connector): Fix flaky test testCatalogStatusReportsARegistrationFailure Co-Authored-By: Claude Opus 5 <[email protected]> --- .../org/apache/gravitino/trino/connector/TestGravitinoConnector.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/trino-connector/trino-connector/src/test/java/org/apache/gravitino/trino/connector/TestGravitinoConnector.java b/trino-connector/trino-connector/src/test/java/org/apache/gravitino/trino/connector/TestGravitinoConnector.java index 9d889c5dc3..b1d9465ba1 100644 --- a/trino-connector/trino-connector/src/test/java/org/apache/gravitino/trino/connector/TestGravitinoConnector.java +++ b/trino-connector/trino-connector/src/test/java/org/apache/gravitino/trino/connector/TestGravitinoConnector.java @@ -387,7 +387,9 @@ public abstract class TestGravitinoConnector extends AbstractGravitinoConnectorT MaterializedRow row = result.getMaterializedRows().get(0); assertEquals(row.getField(0), "FAILED"); assertThat((String) row.getField(1)).contains("unknown-direct-key"); - assertEquals(row.getField(2), 1L); + // The load loop retries failed catalogs on every metadata refresh, so a refresh that lands + // between the procedure call and this query bumps the count past the initial failure. + assertThat((Long) row.getField(2)).isGreaterThanOrEqualTo(1L); } finally { // Leave the shared query runner as it was found, or the load loop keeps retrying this catalog // and the other status table tests see an extra row.
