Details
-
Bug
-
Status: Resolved
-
Trivial
-
Resolution: Fixed
-
None
-
None
-
None
-
Reviewed
Description
The function is TestNodeStatusUpdater#testNMRMConnectionConf()
I believe the connectionWaitMs references below were meant to be nmRmConnectionWaitMs.
conf.setLong(YarnConfiguration.NM_RESOURCEMANAGER_CONNECT_MAX_WAIT_MS, nmRmConnectionWaitMs); conf.setLong(YarnConfiguration.RESOURCEMANAGER_CONNECT_MAX_WAIT_MS, connectionWaitMs); ... long t = System.currentTimeMillis(); long duration = t - waitStartTime; boolean waitTimeValid = (duration >= nmRmConnectionWaitMs) && (duration < (*connectionWaitMs* + delta)); if(!waitTimeValid) { // throw exception if NM doesn't retry long enough throw new Exception("NM should have tried re-connecting to RM during " + "period of at least " + *connectionWaitMs* + " ms, but " + "stopped retrying within " + (*connectionWaitMs* + delta) + " ms: " + e, e); }
Attachments
Attachments
Issue Links
- is broken by
-
YARN-4132 Separate configs for nodemanager to resourcemanager connection timeout and retries
- Resolved