You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/04/16 12:03:58 UTC
[incubator-inlong] branch master updated: [INLONG-3761][Manager] Sleep 5 seconds when Flink job was not running (#3762)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new f903183ce [INLONG-3761][Manager] Sleep 5 seconds when Flink job was not running (#3762)
f903183ce is described below
commit f903183ce95136f87b6e928cec2efb89d31ddb16
Author: healchow <he...@gmail.com>
AuthorDate: Sat Apr 16 20:03:53 2022 +0800
[INLONG-3761][Manager] Sleep 5 seconds when Flink job was not running (#3762)
---
inlong-manager/manager-dao/pom.xml | 4 ++++
.../java/org/apache/inlong/manager/plugin/flink/FlinkOperation.java | 6 +++---
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/inlong-manager/manager-dao/pom.xml b/inlong-manager/manager-dao/pom.xml
index f20e2c8ef..9cd40b868 100644
--- a/inlong-manager/manager-dao/pom.xml
+++ b/inlong-manager/manager-dao/pom.xml
@@ -165,6 +165,10 @@
<artifactId>nimbus-jose-jwt</artifactId>
<groupId>com.nimbusds</groupId>
</exclusion>
+ <exclusion>
+ <artifactId>dropwizard-metrics-hadoop-metrics2-reporter</artifactId>
+ <groupId>com.github.joshelser</groupId>
+ </exclusion>
</exclusions>
</dependency>
<dependency>
diff --git a/inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkOperation.java b/inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkOperation.java
index c061f5590..27fcf8a41 100644
--- a/inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkOperation.java
+++ b/inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkOperation.java
@@ -198,11 +198,11 @@ public class FlinkOperation {
}
if (jobStatus == RUNNING) {
- log.info("job status is Running for {}", jobDetailsInfo);
+ log.info("job status is Running for {}", jobId);
break;
}
- log.info("job was not Running for {}", jobDetailsInfo);
- TimeUnit.SECONDS.sleep(5000);
+ log.info("job was not Running for {}", jobId);
+ TimeUnit.SECONDS.sleep(5);
} catch (Exception e) {
log.error("poll job status error for {}, exception: ", flinkInfo, e);
}