From f3f182db9ef194161de6e42edcefe1d378604146 Mon Sep 17 00:00:00 2001
From: liuxin <liu.xin18@zte.com.cn>
Date: Tue, 17 Oct 2017 20:57:55 +0800
Subject: [PATCH] [STORM-2780] MetricsConsumer record unnecessary timestamp

---
 .../jvm/org/apache/storm/metric/LoggingMetricsConsumer.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java b/storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java
index 934bc92c47..f8c0a69795 100644
--- a/storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java
+++ b/storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java
@@ -56,8 +56,7 @@ public void prepare(Map<String, Object> topoConf, Object registrationArgument, T
     @Override
     public void handleDataPoints(TaskInfo taskInfo, Collection<DataPoint> dataPoints) {
         StringBuilder sb = new StringBuilder();
-        String header = String.format("%d\t%15s:%-4d\t%3d:%-11s\t",
-            taskInfo.timestamp,
+        String header = String.format("%15s:%-4d\t%3d:%-11s\t",
             taskInfo.srcWorkerHost, taskInfo.srcWorkerPort,
             taskInfo.srcTaskId,
             taskInfo.srcComponentId);