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:05:12 UTC
[incubator-inlong] branch release-1.1.0 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 release-1.1.0
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/release-1.1.0 by this push:
new 32a0b526c [INLONG-3761][Manager] Sleep 5 seconds when Flink job was not running (#3762)
32a0b526c is described below
commit 32a0b526c99f0fbbf8e85775c3fa504547b9ca57
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 6eee6a901..9f8e9bf9a 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);
}