commit 69db5d08df4ac2fd5d00fb2e873ded226ea67aeb
author Karel Kolman <kkolman@datameer.com> Sun Oct 23 10:41:27 2022 +0200
committer Laszlo Bodor <bodorlaszlo0202@gmail.com> Sun Oct 23 10:42:45 2022 +0200
tree 227e8dec53e220ac6cac049a0fcbda621461c2ed
parent 3fe502d687d1f3f1e8fd698a7ea129cb49005bce

TEZ-4448: Cannot submit Tez job when dag size is exceeds `ipc.maximum.data.length` and S3A is the filesystem (#241) (Karel Kolman reviewed by Laszlo Bodor)

tez-api/src/main/java/org/apache/tez/client/TezClient.java

diff --git a/tez-api/src/main/java/org/apache/tez/client/TezClient.java b/tez-api/src/main/java/org/apache/tez/client/TezClient.java
index a64519a..a2ea436 100644
--- a/tez-api/src/main/java/org/apache/tez/client/TezClient.java
+++ b/tez-api/src/main/java/org/apache/tez/client/TezClient.java
@@ -699,8 +699,8 @@
             + ", max IPC message size= " + amConfig.getTezConfiguration().getInt(
             CommonConfigurationKeys.IPC_MAXIMUM_DATA_LENGTH, CommonConfigurationKeys.IPC_MAXIMUM_DATA_LENGTH_DEFAULT));
         request.writeTo(fsDataOutputStream);
-        request = requestBuilder.clear().setSerializedRequestPath(fs.resolvePath(dagPlanPath).toString()).build();
       }
+      request = requestBuilder.clear().setSerializedRequestPath(fs.resolvePath(dagPlanPath).toString()).build();
     }
 
     DAGClientAMProtocolBlockingPB proxy = null;