From d1f2dd85e3ccc65bbd36a29aa5def91a1f8ca95a Mon Sep 17 00:00:00 2001
From: chong0929 <123624834@qq.com>
Date: Wed, 25 Sep 2019 18:15:25 +0800
Subject: [PATCH] Issues #455 fix
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

OpenTSDBReader多metric仅读取到第一个metric数据问题修复
---
 .../datax/plugin/reader/opentsdbreader/OpenTSDBReader.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/opentsdbreader/OpenTSDBReader.java b/opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/opentsdbreader/OpenTSDBReader.java
index d57456d1..157f484f 100755
--- a/opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/opentsdbreader/OpenTSDBReader.java
+++ b/opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/opentsdbreader/OpenTSDBReader.java
@@ -124,11 +124,12 @@ public class OpenTSDBReader extends Reader {
             if (TimeUtils.isSecond(endTime)) {
                 endTime *= 1000;
             }
-            DateTime startDateTime = new DateTime(TimeUtils.getTimeInHour(startTime));
+            
             DateTime endDateTime = new DateTime(TimeUtils.getTimeInHour(endTime));
 
             // split by metric
             for (String column : columns) {
+                DateTime startDateTime = new DateTime(TimeUtils.getTimeInHour(startTime));
                 // split by time in hour
                 while (startDateTime.isBefore(endDateTime)) {
                     Configuration clone = this.originalConfig.clone();