You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2015/11/24 06:41:09 UTC
[2/2] incubator-kylin git commit: KYLIN-1149 add a sleep when wrong
url is got from yarn
KYLIN-1149 add a sleep when wrong url is got from yarn
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/7e7edff9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/7e7edff9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/7e7edff9
Branch: refs/heads/1.x-staging
Commit: 7e7edff9f5d0097045ffbd561753c437e04b34c3
Parents: f3214dd
Author: shaofengshi <sh...@apache.org>
Authored: Tue Nov 24 11:31:09 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Tue Nov 24 13:41:01 2015 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/job/tools/HadoopStatusGetter.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7e7edff9/job/src/main/java/org/apache/kylin/job/tools/HadoopStatusGetter.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/tools/HadoopStatusGetter.java b/job/src/main/java/org/apache/kylin/job/tools/HadoopStatusGetter.java
index e2c0aa0..a3c411b 100644
--- a/job/src/main/java/org/apache/kylin/job/tools/HadoopStatusGetter.java
+++ b/job/src/main/java/org/apache/kylin/job/tools/HadoopStatusGetter.java
@@ -85,6 +85,7 @@ public class HadoopStatusGetter {
redirect = h.getValue();
if (isValidURL(redirect) == false) {
log.info("Get invalid redirect url, skip it: " + redirect);
+ Thread.sleep(1000l);
continue;
}
} else {
@@ -97,6 +98,7 @@ public class HadoopStatusGetter {
if (isValidURL(redirect) == false) {
log.info("Get invalid redirect url, skip it: " + redirect);
+ Thread.sleep(1000l);
continue;
}
}
@@ -110,6 +112,8 @@ public class HadoopStatusGetter {
url = redirect;
log.debug("Job " + mrJobId + " check redirect url " + url + ".\n");
}
+ } catch (InterruptedException e) {
+ log.error(e.getMessage());
} finally {
get.releaseConnection();
}