diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/common/ColumnHelper.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/common/ColumnHelper.java index 9f95d44..15c3f9c 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/common/ColumnHelper.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/common/ColumnHelper.java @@ -258,7 +258,7 @@ public Object readResult(Result result, byte[] columnQualifierBytes) for (Entry cell : cells.entrySet()) { V value = (V) converter.decodeValue(cell.getValue()); - Long ts = supplementTs ? TimestampGenerator. + long ts = supplementTs ? TimestampGenerator. getTruncatedTimestamp(cell.getKey()) : cell.getKey(); cellResults.put(ts, value); }