You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/03/16 10:12:23 UTC
(incubator-streampark) branch dev updated: [Fix] fix Unstable test case (#3616)
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 7bec013e7 [Fix] fix Unstable test case (#3616)
7bec013e7 is described below
commit 7bec013e788f4683afad76f7517f1961db2272be
Author: VampireAchao <ac...@apache.org>
AuthorDate: Sat Mar 16 18:12:17 2024 +0800
[Fix] fix Unstable test case (#3616)
---
.../apache/streampark/console/core/service/YarnQueueServiceTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java
index aba0586f5..03dad2f81 100644
--- a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java
+++ b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java
@@ -84,7 +84,7 @@ class YarnQueueServiceTest extends SpringUnitTestBase {
queryParams.setTeamId(targetTeamId);
RestRequest request = new RestRequest();
- request.setPageSize(2);
+ request.setPageSize(5);
request.setPageNum(1);
request.setSortField("create_time");
request.setSortOrder("desc");
@@ -93,7 +93,7 @@ class YarnQueueServiceTest extends SpringUnitTestBase {
yarnQueues.getRecords().stream()
.map(YarnQueue::getQueueLabel)
.collect(Collectors.toList()))
- .containsExactlyInAnyOrder(q3AtL3, q3AtL1);
+ .containsExactlyInAnyOrder(q3AtL3, q3AtL1, q2AtL1, q1AtL1);
// Test for 1st page, size = 2, order by create time with queue_label
queryParams.setQueueLabel("q3");