Skip to content

Commit 0c8813f

Browse files
committed
YARN-9327. Improve synchronisation in ProtoUtils#convertToProtoFormat block. Contributed by Bibin A Chundatt.
1 parent 570eee3 commit 0c8813f

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ProtoUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,7 @@ public static ContainerUpdateType convertFromProtoFormat(
412412
/*
413413
* Resource
414414
*/
415-
public static synchronized ResourceProto convertToProtoFormat(Resource r) {
415+
public static ResourceProto convertToProtoFormat(Resource r) {
416416
return ResourcePBImpl.getProto(r);
417417
}
418418

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourcePBImpl.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,14 +75,14 @@ public ResourcePBImpl(ResourceProto proto) {
7575
initResources();
7676
}
7777

78-
public ResourceProto getProto() {
78+
synchronized public ResourceProto getProto() {
7979
mergeLocalToProto();
8080
proto = viaProto ? proto : builder.build();
8181
viaProto = true;
8282
return proto;
8383
}
8484

85-
private void maybeInitBuilder() {
85+
synchronized private void maybeInitBuilder() {
8686
if (viaProto || builder == null) {
8787
builder = ResourceProto.newBuilder(proto);
8888
}
@@ -131,7 +131,7 @@ public void setVirtualCores(int vCores) {
131131
resources[VCORES_INDEX].setValue(vCores);
132132
}
133133

134-
private void initResources() {
134+
synchronized private void initResources() {
135135
if (this.resources != null) {
136136
return;
137137
}

0 commit comments

Comments
 (0)