This is an automated email from the ASF dual-hosted git repository.

abstractdog pushed a commit to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/tez.git


The following commit(s) were added to refs/heads/branch-0.9 by this push:
     new 69db5d08d 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)
69db5d08d is described below

commit 69db5d08df4ac2fd5d00fb2e873ded226ea67aeb
Author: Karel Kolman <[email protected]>
AuthorDate: Sun Oct 23 10:41:27 2022 +0200

    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 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 a64519a1d..a2ea43643 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 @@ public class TezClient {
             + ", 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;

Reply via email to