(incubator-streampark) branch dev updated: [Fix] fix Unstable test case (#3616)

[benjobs]

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");