[Improve][RestAPI] add e2e test

apache · Mar 6, 2024 · 81c2f33 · 81c2f33
1 parent 0729bbf
commit 81c2f33
Showing 1 changed file with 34 additions and 0 deletions.
diff --git a/...connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java b/...connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
@@ -108,6 +108,40 @@ public void testGetRunningJobById() {
                         });
     }
 
+    @Test
+    public void testGetAnNotExistJobById() {
+        Arrays.asList(node2, node1)
+                .forEach(
+                        instance -> {
+                            given().get(
+                                            HOST
+                                                    + instance.getCluster()
+                                                            .getLocalMember()
+                                                            .getAddress()
+                                                            .getPort()
+                                                    + RestConstant.RUNNING_JOB_URL
+                                                    + "/"
+                                                    + 123)
+                                    .then()
+                                    .statusCode(200)
+                                    .body("jobId", equalTo("123"));
+                        });
+        Arrays.asList(node2, node1)
+                .forEach(
+                        instance -> {
+                            given().get(
+                                            HOST
+                                                    + instance.getCluster()
+                                                            .getLocalMember()
+                                                            .getAddress()
+                                                            .getPort()
+                                                    + RestConstant.RUNNING_JOB_URL
+                                                    + "/")
+                                    .then()
+                                    .statusCode(500);
+                        });
+    }
+
     @Test
     public void testGetRunningJobs() {
         Arrays.asList(node2, node1)