Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-6323. Rolling upgrade/config change is broken on timeline v2. (Vrushali C via Haibo Chen)

Browse Source
This commit is contained in:
Haibo Chen 2017-08-21 10:45:10 -07:00 committed by Varun Saxena
parent cbd5e89b24
commit 0f51f15097
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/YarnConfiguration.java
View File

@ -2312,6 +2312,8 @@ public static boolean isAclEnabled(Configuration conf) {
public static final int DEFAULT_NUMBER_OF_ASYNC_ENTITIES_TO_MERGE = 10; public static final int DEFAULT_NUMBER_OF_ASYNC_ENTITIES_TO_MERGE = 10;
/** default version for any flow. */
public static final String DEFAULT_FLOW_VERSION = "1";
/** /**
* The time period for which timeline v2 client will wait for draining * The time period for which timeline v2 client will wait for draining

10
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/ContainerManagerImpl.java
View File

@ -410,6 +410,16 @@ private void recoverApplication(ContainerManagerApplicationProto p)
LOG.debug( LOG.debug(
"Recovering Flow context: " + fc + " for an application " + appId); "Recovering Flow context: " + fc + " for an application " + appId);
} }
} else {
// in upgrade situations, where there is no prior existing flow context,
// default would be used.
fc = new FlowContext(TimelineUtils.generateDefaultFlowName(null, appId),
YarnConfiguration.DEFAULT_FLOW_VERSION, appId.getClusterTimestamp());
if (LOG.isDebugEnabled()) {
LOG.debug(
"No prior existing flow context found. Using default Flow context: "
+ fc + " for an application " + appId);
}
} }
LOG.info("Recovering application " + appId); LOG.info("Recovering application " + appId);