diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateRequestPBImpl.java index bff252f..8ae9f48 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateRequestPBImpl.java @@ -140,13 +140,14 @@ public void setProgress(float progress) { } @Override - public List getAskList() { + public synchronized List getAskList() { initAsks(); return this.ask; } @Override - public void setAskList(final List resourceRequests) { + public synchronized void setAskList( + final List resourceRequests) { if(resourceRequests == null) { return; } @@ -224,12 +225,12 @@ public void remove() { builder.addAllAsk(iterable); } @Override - public List getReleaseList() { + public synchronized List getReleaseList() { initReleases(); return this.release; } @Override - public void setReleaseList(List releaseContainers) { + public synchronized void setReleaseList(List releaseContainers) { if(releaseContainers == null) { return; } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsRequestPBImpl.java index 33f74f0..52b6207 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsRequestPBImpl.java @@ -149,13 +149,13 @@ private void initApplicationStates() { } @Override - public Set getApplicationTypes() { + public synchronized Set getApplicationTypes() { initApplicationTypes(); return this.applicationTypes; } @Override - public void setApplicationTypes(Set applicationTypes) { + public synchronized void setApplicationTypes(Set applicationTypes) { maybeInitBuilder(); if (applicationTypes == null) builder.clearApplicationTypes(); @@ -163,13 +163,14 @@ public void setApplicationTypes(Set applicationTypes) { } @Override - public EnumSet getApplicationStates() { + public synchronized EnumSet getApplicationStates() { initApplicationStates(); return this.applicationStates; } @Override - public void setApplicationStates(EnumSet applicationStates) { + public synchronized void setApplicationStates( + EnumSet applicationStates) { maybeInitBuilder(); if (applicationStates == null) { builder.clearApplicationStates(); diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsResponsePBImpl.java index 453fc89..fe1edd8 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetApplicationsResponsePBImpl.java @@ -55,13 +55,14 @@ public GetApplicationsResponsePBImpl(GetApplicationsResponseProto proto) { } @Override - public List getApplicationList() { + public synchronized List getApplicationList() { initLocalApplicationsList(); return this.applicationList; } @Override - public void setApplicationList(List applications) { + public synchronized void setApplicationList( + List applications) { maybeInitBuilder(); if (applications == null) builder.clearApplications(); diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesRequestPBImpl.java index 09c0fc7..b86b07d 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesRequestPBImpl.java @@ -60,13 +60,13 @@ public GetClusterNodesRequestProto getProto() { } @Override - public EnumSet getNodeStates() { + public synchronized EnumSet getNodeStates() { initNodeStates(); return this.states; } @Override - public void setNodeStates(final EnumSet states) { + public synchronized void setNodeStates(final EnumSet states) { initNodeStates(); this.states.clear(); if (states == null) { diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesResponsePBImpl.java index 04530e5..7b531df 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetClusterNodesResponsePBImpl.java @@ -54,13 +54,13 @@ public GetClusterNodesResponsePBImpl(GetClusterNodesResponseProto proto) { } @Override - public List getNodeReports() { + public synchronized List getNodeReports() { initLocalNodeManagerInfosList(); return this.nodeManagerInfoList; } @Override - public void setNodeReports(List nodeManagers) { + public synchronized void setNodeReports(List nodeManagers) { if (nodeManagers == null) { builder.clearNodeReports(); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesRequestPBImpl.java index bbc1492..4d1f8d8 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesRequestPBImpl.java @@ -126,13 +126,13 @@ private void initLocalContainerIds() { } @Override - public List getContainerIds() { + public synchronized List getContainerIds() { initLocalContainerIds(); return this.containerIds; } @Override - public void setContainerIds(List containerIds) { + public synchronized void setContainerIds(List containerIds) { maybeInitBuilder(); if (containerIds == null) builder.clearContainerId(); diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesResponsePBImpl.java index fb8885b..4223837 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetContainerStatusesResponsePBImpl.java @@ -169,13 +169,13 @@ private void initFailedRequests() { } @Override - public List getContainerStatuses() { + public synchronized List getContainerStatuses() { initLocalContainerStatuses(); return this.containerStatuses; } @Override - public void setContainerStatuses(List statuses) { + public synchronized void setContainerStatuses(List statuses) { maybeInitBuilder(); if (statuses == null) builder.clearStatus(); @@ -183,13 +183,13 @@ public void setContainerStatuses(List statuses) { } @Override - public Map getFailedRequests() { + public synchronized Map getFailedRequests() { initFailedRequests(); return this.failedRequests; } @Override - public void setFailedRequests( + public synchronized void setFailedRequests( Map failedRequests) { maybeInitBuilder(); if (failedRequests == null) diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetQueueUserAclsInfoResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetQueueUserAclsInfoResponsePBImpl.java index 8d405d9..88753fe 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetQueueUserAclsInfoResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/GetQueueUserAclsInfoResponsePBImpl.java @@ -55,13 +55,14 @@ public GetQueueUserAclsInfoResponsePBImpl( } @Override - public List getUserAclsInfoList() { + public synchronized List getUserAclsInfoList() { initLocalQueueUserAclsList(); return queueUserAclsInfoList; } @Override - public void setUserAclsInfoList(List queueUserAclsList) { + public synchronized void setUserAclsInfoList( + List queueUserAclsList) { if (queueUserAclsList == null) { builder.clearQueueUserAcls(); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/RegisterApplicationMasterResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/RegisterApplicationMasterResponsePBImpl.java index 486304c..bd3986c 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/RegisterApplicationMasterResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/RegisterApplicationMasterResponsePBImpl.java @@ -140,7 +140,7 @@ public void setMaximumResourceCapability(Resource capability) { } @Override - public Map getApplicationACLs() { + public synchronized Map getApplicationACLs() { initApplicationACLs(); return this.applicationACLS; } @@ -200,7 +200,7 @@ public void remove() { } @Override - public void setApplicationACLs( + public synchronized void setApplicationACLs( final Map appACLs) { if (appACLs == null) return; diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersRequestPBImpl.java index 2233705..ccc540a 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersRequestPBImpl.java @@ -110,7 +110,8 @@ private void initLocalRequests() { } @Override - public void setStartContainerRequests(List requests) { + public synchronized void setStartContainerRequests( + List requests) { maybeInitBuilder(); if (requests == null) { builder.clearStartContainerRequest(); @@ -119,7 +120,7 @@ public void setStartContainerRequests(List requests) { } @Override - public List getStartContainerRequests() { + public synchronized List getStartContainerRequests() { if (this.requests != null) { return this.requests; } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersResponsePBImpl.java index 8f5c740..a229687 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StartContainersResponsePBImpl.java @@ -145,13 +145,14 @@ private void maybeInitBuilder() { } @Override - public Map getAllServicesMetaData() { + public synchronized Map getAllServicesMetaData() { initServicesMetaData(); return this.servicesMetaData; } @Override - public void setAllServicesMetaData(Map servicesMetaData) { + public synchronized void setAllServicesMetaData( + Map servicesMetaData) { if (servicesMetaData == null) { return; } @@ -274,13 +275,13 @@ private void initSucceededContainers() { } @Override - public List getSuccessfullyStartedContainers() { + public synchronized List getSuccessfullyStartedContainers() { initSucceededContainers(); return this.succeededContainers; } @Override - public void setSuccessfullyStartedContainers( + public synchronized void setSuccessfullyStartedContainers( List succeededContainers) { maybeInitBuilder(); if (succeededContainers == null) { @@ -303,13 +304,13 @@ private void initFailedContainers() { } @Override - public Map getFailedRequests() { + public synchronized Map getFailedRequests() { initFailedContainers(); return this.failedContainers; } @Override - public void setFailedRequests( + public synchronized void setFailedRequests( Map failedContainers) { maybeInitBuilder(); if (failedContainers == null) diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersRequestPBImpl.java index 27e092b..ccbda77 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersRequestPBImpl.java @@ -124,13 +124,13 @@ private void initLocalContainerIds() { } @Override - public List getContainerIds() { + public synchronized List getContainerIds() { initLocalContainerIds(); return this.containerIds; } @Override - public void setContainerIds(List containerIds) { + public synchronized void setContainerIds(List containerIds) { maybeInitBuilder(); if (containerIds == null) builder.clearContainerId(); diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersResponsePBImpl.java index dd28b06..26b48dd 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/StopContainersResponsePBImpl.java @@ -187,13 +187,14 @@ private void initFailedRequests() { } @Override - public List getSuccessfullyStoppedContainers() { + public synchronized List getSuccessfullyStoppedContainers() { initSucceededRequests(); return this.succeededRequests; } @Override - public void setSuccessfullyStoppedContainers(List succeededRequests) { + public synchronized void setSuccessfullyStoppedContainers( + List succeededRequests) { maybeInitBuilder(); if (succeededRequests == null) { builder.clearSucceededRequests(); @@ -202,13 +203,13 @@ public void setSuccessfullyStoppedContainers(List succeededRequests } @Override - public Map getFailedRequests() { + public synchronized Map getFailedRequests() { initFailedRequests(); return this.failedRequests; } @Override - public void setFailedRequests( + public synchronized void setFailedRequests( Map failedRequests) { maybeInitBuilder(); if (failedRequests == null) diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ContainerLaunchContextPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ContainerLaunchContextPBImpl.java index 12dcfcd..4d7c264 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ContainerLaunchContextPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ContainerLaunchContextPBImpl.java @@ -138,7 +138,7 @@ private void maybeInitBuilder() { } @Override - public List getCommands() { + public synchronized List getCommands() { initCommands(); return this.commands; } @@ -157,7 +157,7 @@ private void initCommands() { } @Override - public void setCommands(final List commands) { + public synchronized void setCommands(final List commands) { if (commands == null) return; initCommands(); @@ -174,7 +174,7 @@ private void addCommandsToProto() { } @Override - public Map getLocalResources() { + public synchronized Map getLocalResources() { initLocalResources(); return this.localResources; } @@ -193,7 +193,7 @@ private void initLocalResources() { } @Override - public void setLocalResources( + public synchronized void setLocalResources( final Map localResources) { if (localResources == null) return; @@ -261,7 +261,7 @@ public void setTokens(ByteBuffer tokens) { } @Override - public Map getServiceData() { + public synchronized Map getServiceData() { initServiceData(); return this.serviceData; } @@ -280,7 +280,8 @@ private void initServiceData() { } @Override - public void setServiceData(final Map serviceData) { + public synchronized void setServiceData( + final Map serviceData) { if (serviceData == null) return; initServiceData(); @@ -324,7 +325,7 @@ public boolean hasNext() { } @Override - public Map getEnvironment() { + public synchronized Map getEnvironment() { initEnv(); return this.environment; } @@ -343,7 +344,7 @@ private void initEnv() { } @Override - public void setEnvironment(final Map env) { + public synchronized void setEnvironment(final Map env) { if (env == null) return; initEnv(); @@ -388,7 +389,7 @@ public boolean hasNext() { } @Override - public Map getApplicationACLs() { + public synchronized Map getApplicationACLs() { initApplicationACLs(); return this.applicationACLS; } @@ -447,7 +448,7 @@ public void remove() { } @Override - public void setApplicationACLs( + public synchronized void setApplicationACLs( final Map appACLs) { if (appACLs == null) return; diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueInfoPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueInfoPBImpl.java index 56a5b58..da1fb58 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueInfoPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueInfoPBImpl.java @@ -55,7 +55,7 @@ public QueueInfoPBImpl(QueueInfoProto proto) { } @Override - public List getApplications() { + public synchronized List getApplications() { initLocalApplicationsList(); return this.applicationsList; } @@ -67,7 +67,7 @@ public float getCapacity() { } @Override - public List getChildQueues() { + public synchronized List getChildQueues() { initLocalChildQueuesList(); return this.childQueuesList; } @@ -100,7 +100,8 @@ public QueueState getQueueState() { } @Override - public void setApplications(List applications) { + public synchronized void + setApplications(List applications) { if (applications == null) { builder.clearApplications(); } @@ -114,7 +115,7 @@ public void setCapacity(float capacity) { } @Override - public void setChildQueues(List childQueues) { + public synchronized void setChildQueues(List childQueues) { if (childQueues == null) { builder.clearChildQueues(); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueUserACLInfoPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueUserACLInfoPBImpl.java index 4aa9b09..2b36432 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueUserACLInfoPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/QueueUserACLInfoPBImpl.java @@ -58,7 +58,7 @@ public String getQueueName() { } @Override - public List getUserAcls() { + public synchronized List getUserAcls() { initLocalQueueUserAclsList(); return this.userAclsList; } @@ -74,7 +74,7 @@ public void setQueueName(String queueName) { } @Override - public void setUserAcls(List userAclsList) { + public synchronized void setUserAcls(List userAclsList) { if (userAclsList == null) { builder.clearUserAcls(); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourceBlacklistRequestPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourceBlacklistRequestPBImpl.java index 743e5d1..1b99d64 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourceBlacklistRequestPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourceBlacklistRequestPBImpl.java @@ -118,13 +118,13 @@ private void initBlacklistRemovals() { } @Override - public List getBlacklistAdditions() { + public synchronized List getBlacklistAdditions() { initBlacklistAdditions(); return this.blacklistAdditions; } @Override - public void setBlacklistAdditions(List resourceNames) { + public synchronized void setBlacklistAdditions(List resourceNames) { if (resourceNames == null || resourceNames.isEmpty()) { if (this.blacklistAdditions != null) { this.blacklistAdditions.clear(); @@ -137,13 +137,13 @@ public void setBlacklistAdditions(List resourceNames) { } @Override - public List getBlacklistRemovals() { + public synchronized List getBlacklistRemovals() { initBlacklistRemovals(); return this.blacklistRemovals; } @Override - public void setBlacklistRemovals(List resourceNames) { + public synchronized void setBlacklistRemovals(List resourceNames) { if (resourceNames == null || resourceNames.isEmpty()) { if (this.blacklistRemovals != null) { this.blacklistRemovals.clear();