YARN-6074. FlowRunEntity does not deserialize long values correctly (Rohith Sharma K S via Varun Saxena)
(cherry picked from commit db490eccce
)
This commit is contained in:
parent
1e5e4a52f7
commit
d12920b10e
|
@ -100,7 +100,7 @@ public class FlowRunEntity extends HierarchicalTimelineEntity {
|
||||||
|
|
||||||
public long getRunId() {
|
public long getRunId() {
|
||||||
Object runId = getInfo().get(FLOW_RUN_ID_INFO_KEY);
|
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) {
|
public void setRunId(long runId) {
|
||||||
|
@ -117,7 +117,7 @@ public class FlowRunEntity extends HierarchicalTimelineEntity {
|
||||||
|
|
||||||
public long getMaxEndTime() {
|
public long getMaxEndTime() {
|
||||||
Object time = getInfo().get(FLOW_RUN_END_TIME);
|
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) {
|
public void setMaxEndTime(long endTime) {
|
||||||
|
|
Loading…
Reference in New Issue