From d12920b10eeb10d754ab76d1dc4248c5026849e9 Mon Sep 17 00:00:00 2001 From: Varun Saxena Date: Mon, 9 Jan 2017 18:54:22 +0530 Subject: [PATCH] YARN-6074. FlowRunEntity does not deserialize long values correctly (Rohith Sharma K S via Varun Saxena) (cherry picked from commit db490eccced3c42ac27253ca6cbaf10a77e0e116) --- .../yarn/api/records/timelineservice/FlowRunEntity.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 410a1bf0e6f..5c666cdeb7b 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) {