maheshrajus opened a new pull request, #520: URL: https://github.com/apache/tez/pull/520
#### Root causes and fixes: 1) TestAMRecoveryAggregationBroadcast.testMapJoinTemporalFailure **(race condition)** Replace fixed Thread.sleep(10s) before AM kill with a deterministic waitForVertexSucceeded() helper that polls DAGClient.getVertexStatus() every 500ms (up to 60s) until the target vertices reach SUCCEEDED state. Each test now waits for only the vertices it logically depends on before killing the AM, ensuring the recovery log assertions always see the expected counts. Make OUT_PATH unique per test run (random suffix) to eliminate cross-test. 2) DAGClientRPCImpl / TezClientUtils: port out of range:-1 **(YARN-808 gap)** YARN sets rpcPort=-1 when an AM container is allocated (state=RUNNING) but the AM has not yet bound its RPC listener. The existing guard only checked rpcPort==0 (protobuf default), so rpcPort==-1 reached NetUtils.createSocketAddrForHost(), which threw IllegalArgumentException: port out of range:-1. Fix DAGClientRPCImpl.createAMProxyIfNeeded(): rpcPort == 0 → rpcPort <= 0. Fix TezClientUtils.getAMProxy(FrameworkClient,...): add the same rpcPort <= 0 guard -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
