File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed
src/main/java/com/alipay/oceanbase/rpc/stream Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -84,8 +84,10 @@ public void init() throws Exception {
8484 it = expectant .entrySet ().iterator ();
8585 retryTimes ++;
8686 if (retryTimes > maxRetries ) {
87- RUNTIME .error ("Fail to get refresh table entry response after {}" , retryTimes );
88- throw new ObTableRetryExhaustedException ("Fail to get refresh table entry response after " + retryTimes );
87+ RUNTIME .error ("Fail to get refresh table entry response after {}" ,
88+ retryTimes );
89+ throw new ObTableRetryExhaustedException (
90+ "Fail to get refresh table entry response after " + retryTimes );
8991
9092 }
9193 } else {
@@ -237,8 +239,10 @@ public boolean next() throws Exception {
237239 it = expectant .entrySet ().iterator ();
238240 retryTimes ++;
239241 if (retryTimes > client .getTableEntryRefreshTryTimes ()) {
240- RUNTIME .error ("Fail to get refresh table entry response after {}" , retryTimes );
241- throw new ObTableRetryExhaustedException ("Fail to get refresh table entry response after " + retryTimes );
242+ RUNTIME .error ("Fail to get refresh table entry response after {}" ,
243+ retryTimes );
244+ throw new ObTableRetryExhaustedException (
245+ "Fail to get refresh table entry response after " + retryTimes );
242246 }
243247 continue ;
244248 } else {
You can’t perform that action at this time.
0 commit comments