hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-07 02:51:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[Redis] Note that each Redis Connect retry takes two minutes (#12183)

Browse source 
* Slightly alter error message so it's the same in both cases.

* Each retry takes about two minutes.
This commit is contained in:
dHannasch 2021-01-06 12:00:58 -07:00 • committed by GitHub
parent 97211a6170
commit 695833082d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/ray/gcs/redis_context.cc
View file

@ -332,17 +332,9 @@ Status ConnectWithRetries(const std::string &address, int port,
<< errorMessage; << errorMessage;
break; break;
} }
if (*context == nullptr) { RAY_LOG(WARNING) << errorMessage << " Will retry in "
RAY_LOG(WARNING) << errorMessage << " Will retry in " << RayConfig::instance().redis_db_connect_wait_milliseconds()
<< RayConfig::instance().redis_db_connect_wait_milliseconds() << " milliseconds. Each retry takes about two minutes.";
<< " milliseconds.";
} else if ((*context)->err) {
RAY_LOG(WARNING) << "Could not establish connection to Redis " << address << ":"
<< port << " (context.err = " << (*context)->err
<< "), will retry in "
<< RayConfig::instance().redis_db_connect_wait_milliseconds()
<< " milliseconds.";
}
// Sleep for a little. // Sleep for a little.
std::this_thread::sleep_for(std::chrono::milliseconds( std::this_thread::sleep_for(std::chrono::milliseconds(
RayConfig::instance().redis_db_connect_wait_milliseconds())); RayConfig::instance().redis_db_connect_wait_milliseconds()));