YARN-6074. FlowRunEntity does not deserialize long values correctly (Rohith Sharma K S via Varun Saxena)
(cherry picked from commit db490eccced3c42ac27253ca6cbaf10a77e0e116) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/cec92566 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/cec92566 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/cec92566 Branch: refs/heads/YARN-5355-branch-2 Commit: cec92566d0419148f49268966e51d55b68cc28b7 Parents: fa5fb6c Author: Varun Saxena <varunsax...@apache.org> Authored: Mon Jan 9 18:54:22 2017 +0530 Committer: Varun Saxena <varunsax...@apache.org> Committed: Tue Apr 25 23:14:28 2017 +0530 ---------------------------------------------------------------------- .../hadoop/yarn/api/records/timelineservice/FlowRunEntity.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/cec92566/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/timelineservice/FlowRunEntity.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/timelineservice/FlowRunEntity.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/timelineservice/FlowRunEntity.java index 410a1bf..5c666cd 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/timelineservice/FlowRunEntity.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/timelineservice/FlowRunEntity.java @@ -100,7 +100,7 @@ public class FlowRunEntity extends HierarchicalTimelineEntity { public long getRunId() { Object runId = getInfo().get(FLOW_RUN_ID_INFO_KEY); - return runId == null ? 0L : (Long) runId; + return runId == null ? 0L : ((Number) runId).longValue(); } public void setRunId(long runId) { @@ -117,7 +117,7 @@ public class FlowRunEntity extends HierarchicalTimelineEntity { public long getMaxEndTime() { Object time = getInfo().get(FLOW_RUN_END_TIME); - return time == null ? 0L : (Long)time; + return time == null ? 0L : ((Number) time).longValue(); } public void setMaxEndTime(long endTime) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
