commit 2154128c971b50fedc11e12ec566beaf369e7bbc
author Dimuthu Wannipurage <dimuthu.wannipurage@datasprouts.com> Fri Nov 30 15:36:56 2018 +0530
committer Dimuthu Wannipurage <dimuthu.wannipurage@datasprouts.com> Fri Nov 30 15:36:56 2018 +0530
tree e5a5933695605c90066507ce3240b6799fafb1b1
parent e105c7cb8a155ac0aa6b4f9e96b9916b09b7d7c8

Avoiding multiple initializations of WorkflowOperator in participant monitor

modules/airavata-helix/platform-monitor/src/main/java/org/apache/airavata/helix/cluster/monitoring/agents/HelixParticipantMonitor.java

diff --git a/modules/airavata-helix/platform-monitor/src/main/java/org/apache/airavata/helix/cluster/monitoring/agents/HelixParticipantMonitor.java b/modules/airavata-helix/platform-monitor/src/main/java/org/apache/airavata/helix/cluster/monitoring/agents/HelixParticipantMonitor.java
index 6acef12..cb40fb4 100644
--- a/modules/airavata-helix/platform-monitor/src/main/java/org/apache/airavata/helix/cluster/monitoring/agents/HelixParticipantMonitor.java
+++ b/modules/airavata-helix/platform-monitor/src/main/java/org/apache/airavata/helix/cluster/monitoring/agents/HelixParticipantMonitor.java
@@ -84,7 +84,6 @@
         MockTask mockTask  = new MockTask();
         mockTask.setTaskId("Mock-" + UUID.randomUUID().toString());
         try {
-            operator = new WorkflowOperator(helixClusterName, "mock-wf-operator", zkConnectionString);
             String workflow = operator.launchWorkflow(UUID.randomUUID().toString(), Collections.singletonList(mockTask), true, false);
             /*TaskState state = operator.pollForWorkflowCompletion(workflow, Long.parseLong(ServerSettings.getSetting("platform_mock_workflow_timeout_ms")));
             if (state != TaskState.COMPLETED) {