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 fd3f2e068 [Hotfix][CI] Fix the target flink home location setting and
extend the status getter timeout. (#3003)
fd3f2e068 is described below
commit fd3f2e0683795f4a06dd71127fdf2e1eb7387df2
Author: Yuepeng Pan <[email protected]>
AuthorDate: Thu Aug 31 11:47:30 2023 +0800
[Hotfix][CI] Fix the target flink home location setting and extend the
status getter timeout. (#3003)
---
.github/workflows/maven.yml | 2 +-
.../apache/streampark/console/core/service/ApplicationServiceITest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/.github/workflows/maven.yml b/.github/workflows/maven.yml
index 6c7432de6..3e5ee1d25 100644
--- a/.github/workflows/maven.yml
+++ b/.github/workflows/maven.yml
@@ -90,5 +90,5 @@ jobs:
- name: Build with Maven
run: ./mvnw -B clean install -Pshaded,dist -DskipTests
- name: Test with Maven
- run: wget -c
https://dlcdn.apache.org/flink/flink-1.17.1/flink-1.17.1-bin-scala_2.12.tgz -P
/tmp/ && tar -zxvf /tmp/flink-1.17.1-bin-scala_2.12.tgz && ./mvnw -B test
+ run: wget -c
https://dlcdn.apache.org/flink/flink-1.17.1/flink-1.17.1-bin-scala_2.12.tgz -P
/tmp/ && tar -zxvf /tmp/flink-1.17.1-bin-scala_2.12.tgz -C /tmp/ && ./mvnw -B
test
diff --git
a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/ApplicationServiceITest.java
b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/ApplicationServiceITest.java
index 812f5da37..950b2ce2a 100644
---
a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/ApplicationServiceITest.java
+++
b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/ApplicationServiceITest.java
@@ -147,7 +147,7 @@ class ApplicationServiceITest extends
SpringIntegrationTestBase {
return true;
});
- assertThat(completableFuture.get(WATCHING_INTERVAL.toMillis() * 4,
TimeUnit.MILLISECONDS))
+ assertThat(completableFuture.get(WATCHING_INTERVAL.toMillis() * 24,
TimeUnit.MILLISECONDS))
.isEqualTo(true);
}
}