@@ -133,7 +133,7 @@ class StfSenderRpcClientCollection {
133133 }
134134
135135 lNumStfSenders = lSchedulerInst.stf_sender_id_list ().size ();
136- DDDLOG (" Connecting gRPC clients. stfs_num={}" , lNumStfSenders);
136+ DDDLOG (" Connecting gRPC clients. stfs_num={} config={} " , lNumStfSenders, mClients . size () );
137137
138138 // Connect to all StfSenders
139139 for (const std::string &lStfSenderId : lSchedulerInst.stf_sender_id_list ()) {
@@ -146,8 +146,7 @@ class StfSenderRpcClientCollection {
146146
147147 StfSenderConfigStatus lStfSenderStatus;
148148 if (! mDiscoveryConfig ->getStfSenderConfig (lPartId, lStfSenderId, lStfSenderStatus /* out*/ )) {
149- DDDLOG (" Missing StfSender configuration. Connection will be retried. stfs_id={}" ,
150- lStfSenderId);
149+ DDDLOG (" Missing StfSender configuration. Connection will be retried. stfs_id={}" , lStfSenderId);
151150 continue ;
152151 }
153152
@@ -178,7 +177,7 @@ class StfSenderRpcClientCollection {
178177 for (auto &[ mCliId , lClient] : mClients ) {
179178 if (!lClient->is_ready ()) {
180179 lAllConnReady = false ;
181- IDDLOG_RL ( 10000 , " StfSender gRPC client connection is not ready. stfs_id={} grpc_status={}" , mCliId , lClient->grpc_status ());
180+ DDDLOG_RL ( 2000 , " StfSender gRPC client connection is not ready. stfs_id={} grpc_status={}" , mCliId , lClient->grpc_status ());
182181 }
183182 }
184183 }
0 commit comments