You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/05/13 20:34:36 UTC
airavata git commit: Fixed NPE throws from reInvoked Output Handler
method.
Repository: airavata
Updated Branches:
refs/heads/master a6a80d5ac -> aa7af1bc3
Fixed NPE throws from reInvoked Output Handler method.
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/aa7af1bc
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/aa7af1bc
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/aa7af1bc
Branch: refs/heads/master
Commit: aa7af1bc34ed7fec7b66a9ab5d5806815ad4a9f0
Parents: a6a80d5
Author: shamrath <sh...@gmail.com>
Authored: Wed May 13 14:34:34 2015 -0400
Committer: shamrath <sh...@gmail.com>
Committed: Wed May 13 14:34:34 2015 -0400
----------------------------------------------------------------------
.../airavata/gfac/core/cpi/BetterGfacImpl.java | 23 --------------------
1 file changed, 23 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/aa7af1bc/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/cpi/BetterGfacImpl.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/cpi/BetterGfacImpl.java b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/cpi/BetterGfacImpl.java
index 2530b35..3d5c580 100644
--- a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/cpi/BetterGfacImpl.java
+++ b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/cpi/BetterGfacImpl.java
@@ -1092,29 +1092,6 @@ public class BetterGfacImpl implements GFac,Watcher {
// TODO - Did refactoring, but need to recheck the logic again.
public void reInvokeOutFlowHandlers(JobExecutionContext jobExecutionContext) throws GFacException {
- String experimentPath = null;
- try {
- jobExecutionContext.setZk(new ZooKeeper(AiravataZKUtils.getZKhostPort(), AiravataZKUtils.getZKTimeout(), this));
- zk = jobExecutionContext.getZk();
- log.info("Waiting for zookeeper to connect to the server");
- synchronized (mutex) {
- mutex.wait(5000); // waiting for the syncConnected event
- }
- if (jobExecutionContext.getZk().exists(experimentPath, false) == null) {
- log.error("Experiment is already finalized so no output handlers will be invoked");
- return;
- }
- } catch (IOException e) {
- log.error(e.getMessage(), e);
- } catch (ApplicationSettingsException e) {
- log.error(e.getMessage(), e);
- } catch (InterruptedException e) {
- log.error(e.getMessage(), e);
- } catch (KeeperException e) {
- log.error(e.getMessage(), e);
- }
-
-
GFacConfiguration gFacConfiguration = jobExecutionContext.getGFacConfiguration();
List<GFacHandlerConfig> handlers = null;
if (gFacConfiguration != null) {