github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 13:02:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update OpenTSDBReader.java

Browse Source 
issues #455 fix，OpenTSDBReader多metric仅读取到第一个metric数据问题修复
This commit is contained in:
chong0929 2019-09-25 18:06:30 +08:00 committed by GitHub
parent 57c8dd8673
commit ba67137040
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/opentsdbreader/OpenTSDBReader.java
View File

@ -124,11 +124,12 @@ public class OpenTSDBReader extends Reader {
if (TimeUtils.isSecond(endTime)) { if (TimeUtils.isSecond(endTime)) {
endTime *= 1000; endTime *= 1000;
} }
DateTime startDateTime = new DateTime(TimeUtils.getTimeInHour(startTime));
DateTime endDateTime = new DateTime(TimeUtils.getTimeInHour(endTime)); DateTime endDateTime = new DateTime(TimeUtils.getTimeInHour(endTime));
// split by metric // split by metric
for (String column : columns) { for (String column : columns) {
DateTime startDateTime = new DateTime(TimeUtils.getTimeInHour(startTime));
// split by time in hour // split by time in hour
while (startDateTime.isBefore(endDateTime)) { while (startDateTime.isBefore(endDateTime)) {
Configuration clone = this.originalConfig.clone(); Configuration clone = this.originalConfig.clone();