File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/main/java/com/alipay/oceanbase/rpc Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -158,7 +158,6 @@ public class ObTableClient extends AbstractObTableClient implements Lifecycle {
158158
159159 private RouteTableRefresher routeTableRefresher ;
160160
161- private Thread backgroundRefreshTableTask ;
162161 private Long clientId ;
163162 private Map <String , Object > TableConfigs = new HashMap <>();
164163 /*
@@ -183,8 +182,7 @@ public void init() throws Exception {
183182 initMetadata ();
184183 // 5. run fresh table task
185184 routeTableRefresher = new RouteTableRefresher (this );
186- backgroundRefreshTableTask = new Thread (routeTableRefresher );
187- backgroundRefreshTableTask .start ();
185+ routeTableRefresher .start ();
188186 initialized = true ;
189187 } catch (Throwable t ) {
190188 BOOT .warn ("failed to init ObTableClient" , t );
@@ -210,7 +208,9 @@ public void close() throws Exception {
210208 return ;
211209 }
212210 closed = true ;
213- routeTableRefresher .finish ();
211+ if (routeTableRefresher != null ) {
212+ routeTableRefresher .finish ();
213+ }
214214 if (tableRoster != null ) {
215215 Exception throwException = null ;
216216 List <ObServerAddr > exceptionObServers = new ArrayList <ObServerAddr >();
You can’t perform that action at this time.
0 commit comments