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/06/23 03:14:38 UTC
(incubator-streampark) 01/01: [Improve] flink 1.16|1.17 perjob-mode e2e test
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch issue-3760
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit 3d85be457898e97ce1aaa5d28dd2b5e79be17d9e
Author: benjobs <be...@gmail.com>
AuthorDate: Sun Jun 23 11:14:23 2024 +0800
[Improve] flink 1.16|1.17 perjob-mode e2e test
---
.../e2e/cases/ApplicationsFlink116OnYarnTest.java | 37 +++++++++++-----------
.../e2e/cases/ApplicationsFlink117OnYarnTest.java | 37 +++++++++++-----------
2 files changed, 36 insertions(+), 38 deletions(-)
diff --git a/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink116OnYarnTest.java b/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink116OnYarnTest.java
index ea63b2096..91e5c6166 100644
--- a/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink116OnYarnTest.java
+++ b/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink116OnYarnTest.java
@@ -218,25 +218,24 @@ public class ApplicationsFlink116OnYarnTest {
.anyMatch(it -> it.contains("SUCCESS")));
}
-// This test cannot be executed due to a bug, and will be put online after issue #3761 fixed
-// @Test
-// @Order(70)
-// void testStartFlinkApplicationOnYarnPerJobMode() {
-// final ApplicationsPage applicationsPage = new ApplicationsPage(browser);
-//
-// applicationsPage.startApplication(applicationName);
-//
-// Awaitility.await().untilAsserted(() -> assertThat(applicationsPage.applicationsList())
-// .as("Applications list should contain started application")
-// .extracting(WebElement::getText)
-// .anyMatch(it -> it.contains("RUNNING")));
-//
-// Awaitility.await()
-// .untilAsserted(() -> assertThat(applicationsPage.applicationsList())
-// .as("Applications list should contain finished application")
-// .extracting(WebElement::getText)
-// .anyMatch(it -> it.contains("FINISHED")));
-// }
+ @Test
+ @Order(70)
+ void testStartFlinkApplicationOnYarnPerJobMode() {
+ final ApplicationsPage applicationsPage = new ApplicationsPage(browser);
+
+ applicationsPage.startApplication(applicationName);
+
+ Awaitility.await().untilAsserted(() -> assertThat(applicationsPage.applicationsList())
+ .as("Applications list should contain started application")
+ .extracting(WebElement::getText)
+ .anyMatch(it -> it.contains("RUNNING")));
+
+ Awaitility.await()
+ .untilAsserted(() -> assertThat(applicationsPage.applicationsList())
+ .as("Applications list should contain finished application")
+ .extracting(WebElement::getText)
+ .anyMatch(it -> it.contains("FINISHED")));
+ }
@Test
@Order(80)
diff --git a/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink117OnYarnTest.java b/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink117OnYarnTest.java
index ef9905ab5..4c2ac40c2 100644
--- a/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink117OnYarnTest.java
+++ b/streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink117OnYarnTest.java
@@ -218,25 +218,24 @@ public class ApplicationsFlink117OnYarnTest {
.anyMatch(it -> it.contains("SUCCESS")));
}
-// This test cannot be executed due to a bug, and will be put online after issue #3761 fixed
-// @Test
-// @Order(70)
-// void testStartFlinkApplicationOnYarnPerJobMode() {
-// final ApplicationsPage applicationsPage = new ApplicationsPage(browser);
-//
-// applicationsPage.startApplication(applicationName);
-//
-// Awaitility.await().untilAsserted(() -> assertThat(applicationsPage.applicationsList())
-// .as("Applications list should contain started application")
-// .extracting(WebElement::getText)
-// .anyMatch(it -> it.contains("RUNNING")));
-//
-// Awaitility.await()
-// .untilAsserted(() -> assertThat(applicationsPage.applicationsList())
-// .as("Applications list should contain finished application")
-// .extracting(WebElement::getText)
-// .anyMatch(it -> it.contains("FINISHED")));
-// }
+ @Test
+ @Order(70)
+ void testStartFlinkApplicationOnYarnPerJobMode() {
+ final ApplicationsPage applicationsPage = new ApplicationsPage(browser);
+
+ applicationsPage.startApplication(applicationName);
+
+ Awaitility.await().untilAsserted(() -> assertThat(applicationsPage.applicationsList())
+ .as("Applications list should contain started application")
+ .extracting(WebElement::getText)
+ .anyMatch(it -> it.contains("RUNNING")));
+
+ Awaitility.await()
+ .untilAsserted(() -> assertThat(applicationsPage.applicationsList())
+ .as("Applications list should contain finished application")
+ .extracting(WebElement::getText)
+ .anyMatch(it -> it.contains("FINISHED")));
+ }
@Test
@Order(80)