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

Merge d1f2dd85e3 into 0824b45c5e

Browse Source
This commit is contained in:
Xiaochong Wu 2025-04-10 16:23:58 +08:00 committed by GitHub
commit 9c4dc2be24
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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

@ -140,11 +140,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();