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 <[email protected]> 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)
