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

opentsdb读取任务设置多指标只能读取到第一个指标bug

Browse Source
This commit is contained in:
rubybj 2020-04-27 17:27:50 +08:00
parent 3b3fa878db
commit 74ef652fdf
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -124,12 +124,13 @@ 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 startDateTime=null;
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) {
// split by time in hour // split by time in hour
//When the metric is multiple, the startDateTime needs to be reset
startDateTime = new DateTime(TimeUtils.getTimeInHour(startTime));
while (startDateTime.isBefore(endDateTime)) { while (startDateTime.isBefore(endDateTime)) {
Configuration clone = this.originalConfig.clone(); Configuration clone = this.originalConfig.clone();
clone.set(Key.COLUMN, Collections.singletonList(column)); clone.set(Key.COLUMN, Collections.singletonList(column));