This is an automated email from the ASF dual-hosted git repository.
yashmayya pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 109d3917a89 Fix a flaky assert when testing OOM Cancellation of MSE
Queries (#16533)
109d3917a89 is described below
commit 109d3917a89758416c653f0de785ed24226a78ac
Author: Rajat Venkatesh <[email protected]>
AuthorDate: Thu Aug 7 13:00:28 2025 +0530
Fix a flaky assert when testing OOM Cancellation of MSE Queries (#16533)
---
.../tests/OfflineClusterMemBasedServerQueryKillingTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterMemBasedServerQueryKillingTest.java
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterMemBasedServerQueryKillingTest.java
index efa34e69eb5..990a1b41cc6 100644
---
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterMemBasedServerQueryKillingTest.java
+++
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterMemBasedServerQueryKillingTest.java
@@ -291,7 +291,7 @@ public class OfflineClusterMemBasedServerQueryKillingTest
extends BaseClusterInt
JsonNode queryResponse = postQuery(OOM_QUERY);
String exceptionsNode = queryResponse.get("exceptions").toString();
assertTrue(exceptionsNode.contains("\"errorCode\":" +
QueryErrorCode.INTERNAL.getId()), exceptionsNode);
- assertTrue(exceptionsNode.contains("Received 1 error from stage 1"),
exceptionsNode);
+ assertTrue(exceptionsNode.contains("Received 1 error"), exceptionsNode);
assertTrue(_testAccountant.hasCallback());
assertEquals(queryResponse.get("requestId").asText(),
_testAccountant.getQueryResourceTracker().getQueryId());
}
@@ -327,7 +327,7 @@ public class OfflineClusterMemBasedServerQueryKillingTest
extends BaseClusterInt
String exceptionsNode = queryResponse.get("exceptions").toString();
assertTrue(exceptionsNode.contains("\"errorCode\":" +
QueryErrorCode.INTERNAL.getId()), exceptionsNode);
- assertTrue(exceptionsNode.contains("Received 1 error from stage 1"),
exceptionsNode);
+ assertTrue(exceptionsNode.contains("Received 1 error"), exceptionsNode);
assertTrue(_testAccountant.hasCallback());
assertEquals(queryResponse.get("requestId").asText(),
_testAccountant.getQueryResourceTracker().getQueryId());
}
@@ -347,7 +347,7 @@ public class OfflineClusterMemBasedServerQueryKillingTest
extends BaseClusterInt
JsonNode queryResponse = postQuery(OOM_QUERY_2);
String exceptionsNode = queryResponse.get("exceptions").toString();
assertTrue(exceptionsNode.contains("\"errorCode\":" +
QueryErrorCode.INTERNAL.getId()), exceptionsNode);
- assertTrue(exceptionsNode.contains("Received 1 error from stage 1"),
exceptionsNode);
+ assertTrue(exceptionsNode.contains("Received 1 error"), exceptionsNode);
assertTrue(_testAccountant.hasCallback());
assertEquals(queryResponse.get("requestId").asText(),
_testAccountant.getQueryResourceTracker().getQueryId());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
