StormClusterState clusterState = data.getStormClusterState();
topologyMetricInfo.set_topology_id(topologyId);
try {
//update task metrics list
Map<Integer, TaskInfo> taskInfoList = clusterState.task_info_list(topologyId);
List<TaskMetricInfo> taskMetricList = clusterState.get_task_metric_list(topologyId);
for(TaskMetricInfo taskMetricInfo : taskMetricList) {
TaskMetricData taskMetricData = new TaskMetricData();
NimbusUtils.updateTaskMetricData(taskMetricData, taskMetricInfo);
TaskInfo taskInfo = taskInfoList.get(Integer.parseInt(taskMetricInfo.getTaskId()));