Forráskód Böngészése

HDDS-2075. Tracing in OzoneManager call is propagated with wrong parent (#1415)

(cherry picked from commit 64ed6b177d6b00b22d45576a8517432dc6c03348)
Doroszlai, Attila 5 éve
szülő
commit
d8c98c5fc1

+ 5 - 2
hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java

@@ -150,8 +150,11 @@ public class RpcClient implements ClientProtocol {
     this.userRights = aclConfig.getUserDefaultRights();
     this.groupRights = aclConfig.getGroupDefaultRights();
 
-    this.ozoneManagerClient = new OzoneManagerProtocolClientSideTranslatorPB(
-        this.conf, clientId.toString(), ugi);
+    this.ozoneManagerClient = TracingUtil.createProxy(
+        new OzoneManagerProtocolClientSideTranslatorPB(
+            this.conf, clientId.toString(), ugi),
+        OzoneManagerProtocol.class, conf
+    );
     long scmVersion =
         RPC.getProtocolVersion(StorageContainerLocationProtocolPB.class);
     InetSocketAddress scmAddress = getScmAddressForClient();

+ 2 - 3
hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/protocolPB/OzoneManagerProtocolClientSideTranslatorPB.java

@@ -202,10 +202,9 @@ public final class OzoneManagerProtocolClientSideTranslatorPB
         OzoneConfigKeys.OZONE_CLIENT_FAILOVER_SLEEP_MAX_MILLIS_KEY,
         OzoneConfigKeys.OZONE_CLIENT_FAILOVER_SLEEP_MAX_MILLIS_DEFAULT);
 
-    this.rpcProxy = TracingUtil.createProxy(
+    this.rpcProxy =
         createRetryProxy(omFailoverProxyProvider, maxRetries, maxFailovers,
-            sleepBase, sleepMax),
-        OzoneManagerProtocolPB.class, conf);
+            sleepBase, sleepMax);
     this.clientID = clientId;
   }