update

vvaks0 · Dec 27, 2016 · b10c284 · b10c284
1 parent a482b2e
commit b10c284
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/DeviceMonitor/src/main/java/com/hortonworks/iot/topology/DeviceMonitorTopology.java b/DeviceMonitor/src/main/java/com/hortonworks/iot/topology/DeviceMonitorTopology.java
@@ -81,11 +81,11 @@ public static void main(String[] args) {
      TopologyBuilder builder = new TopologyBuilder();
      Constants constants = new Constants();
      String hostClusterName = null; 
-     String deviceLogTable = "device_status_log";
+     String deviceLogTable = "telecom_device_status_log";
      if(args[0] != null){
      	hostClusterName = args[0];
     	topologyName = "DeviceMonitorTopology-"+hostClusterName;
-    	deviceLogTable = "device_status_log_"+hostClusterName;
+    	deviceLogTable = "telecom_device_status_log_"+hostClusterName;
      }
      // Use pipe as record boundary
   	  RecordFormat format = new DelimitedRecordFormat().withFieldDelimiter(",");

diff --git a/redeployApplication.sh b/redeployApplication.sh
@@ -98,7 +98,7 @@ nohup spark-submit --class com.hortonworks.iot.spark.streaming.SparkNostradamus
 
 # Redeploy Storm Topology to send topology meta data to Atlas
 echo "*********************************Redeploying Storm Topology..."
-storm kill DeviceMonitorTopology $CLUSTER_NAME
+storm kill DeviceMonitorTopology-$CLUSTER_NAME
 
 curl -u admin:admin -X DELETE 'http://'"$ATLAS_HOST:$ATLAS_PORT"'/api/atlas/entities?type=storm_topology&property=qualifiedName&value=DeviceMonitorTopology'