private void checkTimeouts ( ) { long waitTime = getMs ( PropertyKey . MASTER_WORKER_CONNECT_WAIT_TIME ) ; long retryInterval = getMs ( PropertyKey . USER_RPC_RETRY_MAX_SLEEP_MS ) ; if ( waitTime < retryInterval ) { LOG . warn ( "{}={}ms is smaller than {}={}ms. Workers might not have enough time to register. " + "Consider either increasing {} or decreasing {}" , PropertyKey . Name . MASTER_WORKER_CONNECT_WAIT_TIME , waitTime , PropertyKey . Name . USER_RPC_RETRY_MAX_SLEEP_MS , retryInterval , PropertyKey . Name . MASTER_WORKER_CONNECT_WAIT_TIME , PropertyKey . Name . USER_RPC_RETRY_MAX_SLEEP_MS ) ; } checkHeartbeatTimeout ( PropertyKey . MASTER_MASTER_HEARTBEAT_INTERVAL , PropertyKey . MASTER_HEARTBEAT_TIMEOUT ) ; // Skip checking block worker heartbeat config because the timeout is master-side while the // heartbeat interval is worker-side. }
Validates timeout related configuration .