This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch Fix-cannot-stop-by-script in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c2cf3d19e23e084ea57456a279d54b2d329e0b72 Author: Yongzao <[email protected]> AuthorDate: Tue Jan 13 13:31:21 2026 +0800 finish --- iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 11 +---------- iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 2 +- 2 files changed, 2 insertions(+), 11 deletions(-) diff --git a/iotdb-core/ainode/iotdb/ainode/core/ai_node.py b/iotdb-core/ainode/iotdb/ainode/core/ai_node.py index d8f619e1b8d..7ad0dce842f 100644 --- a/iotdb-core/ainode/iotdb/ainode/core/ai_node.py +++ b/iotdb-core/ainode/iotdb/ainode/core/ai_node.py @@ -161,13 +161,4 @@ class AINode: if not self._stop_event.is_set(): self._stop_event.set() self._rpc_handler.stop() - if self._rpc_service: - self._rpc_service.stop() - for retry in range(30): - self._rpc_service.join(2) - if not self._rpc_service.is_alive(): - logger.warning( - "RPC service thread failed to stop in time, retrying..." - ) - break - logger.info("IoTDB-AINode has successfully stopped.") + self._rpc_service.stop() diff --git a/iotdb-core/ainode/iotdb/ainode/core/rpc/service.py b/iotdb-core/ainode/iotdb/ainode/core/rpc/service.py index fc93a0cce7d..472b91c204a 100644 --- a/iotdb-core/ainode/iotdb/ainode/core/rpc/service.py +++ b/iotdb-core/ainode/iotdb/ainode/core/rpc/service.py @@ -49,7 +49,7 @@ class AINodeThreadPoolServer(TServer.TThreadPoolServer): self.serverTransport.listen() while not self._stop_event.is_set(): try: - client = self.serverTransport.accept() # TODO: Fix the block problem + client = self.serverTransport.accept() if not client: continue self.clients.put(client)
