This is an automated email from the ASF dual-hosted git repository. hxd pushed a commit to branch cluster- in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9790e83068cc980a5b1a42c6508f28a0c34500e0 Author: xiangdong huang <[email protected]> AuthorDate: Wed Aug 11 01:01:53 2021 +0800 add cluster/server/raft packet --- .gitignore | 1 - .../org/apache/iotdb/cluster/ClusterIoTDB.java | 1 + .../cluster/client/sync/SyncClientFactory.java | 1 + .../iotdb/cluster/client/sync/SyncClientPool.java | 1 + .../iotdb/cluster/client/sync/SyncDataClient.java | 1 + .../client/sync/SyncDataHeartbeatClient.java | 1 + .../iotdb/cluster/client/sync/SyncMetaClient.java | 1 + .../client/sync/SyncMetaHeartbeatClient.java | 1 + .../cluster/partition/slot/SlotPartitionTable.java | 1 + .../handlers/caller/AppendNodeEntryHandler.java | 1 + .../server/handlers/caller/HeartbeatHandler.java | 1 + .../cluster/server/heartbeat/HeartbeatThread.java | 1 + .../server/heartbeat/MetaHeartbeatThread.java | 1 + .../cluster/server/member/DataGroupMember.java | 1 + .../cluster/server/member/MetaGroupMember.java | 1 + .../iotdb/cluster/server/member/RaftMember.java | 3 +- .../raft/DataRaftHeartBeatServiceMBean.java} | 26 ++------------- .../raft/DataRaftServiceMBean.java} | 26 ++------------- .../raft/MetaRaftHeartBeatServiceMBean.java} | 26 ++------------- .../raft/MetaRaftServiceMBean.java} | 26 ++------------- .../raft/RaftServiceHandler.java} | 37 +++++++++++----------- .../server/service/DataGroupServiceImpls.java | 1 + .../cluster/server/service/MetaSyncService.java | 1 + 23 files changed, 44 insertions(+), 117 deletions(-) diff --git a/.gitignore b/.gitignore index 757a55b..a0b9c7b 100644 --- a/.gitignore +++ b/.gitignore @@ -3,7 +3,6 @@ **/logs/* **/lib/** **/data/** -**/raft/** # Python runtime file **/__pycache__/** diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java b/cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java index a8dc705..332c7e1 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDB.java @@ -56,6 +56,7 @@ import org.apache.iotdb.db.service.JMXService; import org.apache.iotdb.db.service.RegisterManager; import org.apache.iotdb.db.service.thrift.ThriftServiceThread; import org.apache.iotdb.db.utils.TestOnly; + import org.apache.thrift.TException; import org.apache.thrift.async.TAsyncClientManager; import org.apache.thrift.protocol.TBinaryProtocol.Factory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java index c34f1f3..fa0da62 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java @@ -21,6 +21,7 @@ package org.apache.iotdb.cluster.client.sync; import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.rpc.thrift.RaftService; + import org.apache.thrift.transport.TTransportException; import java.io.IOException; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientPool.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientPool.java index 38d9942..cdfa5df 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientPool.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientPool.java @@ -26,6 +26,7 @@ import org.apache.iotdb.cluster.rpc.thrift.RaftService.Client; import org.apache.iotdb.cluster.server.monitor.NodeStatusManager; import org.apache.iotdb.cluster.utils.ClusterNode; import org.apache.iotdb.db.utils.TestOnly; + import org.apache.thrift.transport.TTransportException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java index f886363..dcda206 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java @@ -26,6 +26,7 @@ import org.apache.iotdb.db.utils.TestOnly; import org.apache.iotdb.rpc.RpcTransportFactory; import org.apache.iotdb.rpc.TConfigurationConst; import org.apache.iotdb.rpc.TimeoutChangeableTransport; + import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.protocol.TProtocolFactory; import org.apache.thrift.transport.TSocket; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataHeartbeatClient.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataHeartbeatClient.java index c2c7f9a..7024466 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataHeartbeatClient.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataHeartbeatClient.java @@ -24,6 +24,7 @@ import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.utils.ClusterUtils; import org.apache.iotdb.rpc.RpcTransportFactory; import org.apache.iotdb.rpc.TConfigurationConst; + import org.apache.thrift.protocol.TProtocolFactory; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransportException; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java index 588d0cd..28674b8 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java @@ -25,6 +25,7 @@ import org.apache.iotdb.cluster.rpc.thrift.TSMetaService.Client; import org.apache.iotdb.cluster.utils.ClusterUtils; import org.apache.iotdb.rpc.RpcTransportFactory; import org.apache.iotdb.rpc.TConfigurationConst; + import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.protocol.TProtocolFactory; import org.apache.thrift.transport.TSocket; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaHeartbeatClient.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaHeartbeatClient.java index 8c7abec..ad19287 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaHeartbeatClient.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaHeartbeatClient.java @@ -24,6 +24,7 @@ import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.utils.ClusterUtils; import org.apache.iotdb.rpc.RpcTransportFactory; import org.apache.iotdb.rpc.TConfigurationConst; + import org.apache.thrift.protocol.TProtocolFactory; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransportException; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java b/cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java index 61803ef..7a46baa 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotPartitionTable.java @@ -32,6 +32,7 @@ import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.rpc.thrift.RaftNode; import org.apache.iotdb.cluster.utils.NodeSerializeUtils; import org.apache.iotdb.db.utils.SerializeUtils; + import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java index 6da7370..2945726 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/AppendNodeEntryHandler.java @@ -25,6 +25,7 @@ import org.apache.iotdb.cluster.server.member.RaftMember; import org.apache.iotdb.cluster.server.monitor.Peer; import org.apache.iotdb.cluster.server.monitor.Timer; import org.apache.iotdb.cluster.server.monitor.Timer.Statistic; + import org.apache.thrift.async.AsyncMethodCallback; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java index 4b4f4b6..bccb16f 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/HeartbeatHandler.java @@ -23,6 +23,7 @@ import org.apache.iotdb.cluster.rpc.thrift.HeartBeatResponse; import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.server.member.RaftMember; import org.apache.iotdb.cluster.server.monitor.Peer; + import org.apache.thrift.async.AsyncMethodCallback; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java index a7afd0b..e5a59fe 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatThread.java @@ -33,6 +33,7 @@ import org.apache.iotdb.cluster.server.handlers.caller.ElectionHandler; import org.apache.iotdb.cluster.server.handlers.caller.HeartbeatHandler; import org.apache.iotdb.cluster.server.member.RaftMember; import org.apache.iotdb.cluster.utils.ClientUtils; + import org.apache.thrift.TException; import org.apache.thrift.transport.TTransportException; import org.slf4j.Logger; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java index de948ac..f8ce0b8 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java @@ -22,6 +22,7 @@ package org.apache.iotdb.cluster.server.heartbeat; import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.server.NodeCharacter; import org.apache.iotdb.cluster.server.member.MetaGroupMember; + import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java index d288b86..aaba50f 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java @@ -94,6 +94,7 @@ import org.apache.iotdb.db.utils.TestOnly; import org.apache.iotdb.service.rpc.thrift.EndPoint; import org.apache.iotdb.service.rpc.thrift.TSStatus; import org.apache.iotdb.tsfile.utils.Pair; + import org.apache.thrift.protocol.TProtocolFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java index 97822c2..b3dcc7a 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java @@ -96,6 +96,7 @@ import org.apache.iotdb.db.utils.TimeValuePairUtils.Intervals; import org.apache.iotdb.service.rpc.thrift.EndPoint; import org.apache.iotdb.service.rpc.thrift.TSStatus; import org.apache.iotdb.tsfile.read.filter.basic.Filter; + import org.apache.thrift.TException; import org.apache.thrift.protocol.TProtocolFactory; import org.apache.thrift.transport.TTransportException; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java index 2ee8626..87238c4 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java @@ -19,7 +19,6 @@ package org.apache.iotdb.cluster.server.member; -import com.google.common.util.concurrent.ThreadFactoryBuilder; import org.apache.iotdb.cluster.ClusterIoTDB; import org.apache.iotdb.cluster.client.async.AsyncClientPool; import org.apache.iotdb.cluster.client.sync.SyncClientAdaptor; @@ -80,6 +79,8 @@ import org.apache.iotdb.db.utils.TestOnly; import org.apache.iotdb.rpc.RpcUtils; import org.apache.iotdb.rpc.TSStatusCode; import org.apache.iotdb.service.rpc.thrift.TSStatus; + +import com.google.common.util.concurrent.ThreadFactoryBuilder; import org.apache.thrift.TException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatServiceMBean.java similarity index 53% copy from cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java copy to cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatServiceMBean.java index c34f1f3..6f57775 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftHeartBeatServiceMBean.java @@ -16,28 +16,6 @@ * specific language governing permissions and limitations * under the License. */ +package org.apache.iotdb.cluster.server.raft; -package org.apache.iotdb.cluster.client.sync; - -import org.apache.iotdb.cluster.rpc.thrift.Node; -import org.apache.iotdb.cluster.rpc.thrift.RaftService; -import org.apache.thrift.transport.TTransportException; - -import java.io.IOException; - -public interface SyncClientFactory { - - /** - * Get a client which will connect the given node and be cached in the given pool. - * - * @param node the cluster node the client will connect. - * @param pool the pool that will cache the client for reusing. - * @return - * @throws IOException - */ - RaftService.Client getSyncClient(Node node, SyncClientPool pool) throws TTransportException; - - default String nodeInfo(Node node) { - return node.toString(); - } -} +public interface DataRaftHeartBeatServiceMBean {} diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftServiceMBean.java similarity index 53% copy from cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java copy to cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftServiceMBean.java index c34f1f3..dbf80a1 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/DataRaftServiceMBean.java @@ -16,28 +16,6 @@ * specific language governing permissions and limitations * under the License. */ +package org.apache.iotdb.cluster.server.raft; -package org.apache.iotdb.cluster.client.sync; - -import org.apache.iotdb.cluster.rpc.thrift.Node; -import org.apache.iotdb.cluster.rpc.thrift.RaftService; -import org.apache.thrift.transport.TTransportException; - -import java.io.IOException; - -public interface SyncClientFactory { - - /** - * Get a client which will connect the given node and be cached in the given pool. - * - * @param node the cluster node the client will connect. - * @param pool the pool that will cache the client for reusing. - * @return - * @throws IOException - */ - RaftService.Client getSyncClient(Node node, SyncClientPool pool) throws TTransportException; - - default String nodeInfo(Node node) { - return node.toString(); - } -} +public interface DataRaftServiceMBean {} diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatServiceMBean.java similarity index 53% copy from cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java copy to cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatServiceMBean.java index c34f1f3..4db647c 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftHeartBeatServiceMBean.java @@ -16,28 +16,6 @@ * specific language governing permissions and limitations * under the License. */ +package org.apache.iotdb.cluster.server.raft; -package org.apache.iotdb.cluster.client.sync; - -import org.apache.iotdb.cluster.rpc.thrift.Node; -import org.apache.iotdb.cluster.rpc.thrift.RaftService; -import org.apache.thrift.transport.TTransportException; - -import java.io.IOException; - -public interface SyncClientFactory { - - /** - * Get a client which will connect the given node and be cached in the given pool. - * - * @param node the cluster node the client will connect. - * @param pool the pool that will cache the client for reusing. - * @return - * @throws IOException - */ - RaftService.Client getSyncClient(Node node, SyncClientPool pool) throws TTransportException; - - default String nodeInfo(Node node) { - return node.toString(); - } -} +public interface MetaRaftHeartBeatServiceMBean {} diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java similarity index 53% copy from cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java copy to cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java index c34f1f3..43f75b9 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java @@ -16,28 +16,6 @@ * specific language governing permissions and limitations * under the License. */ +package org.apache.iotdb.cluster.server.raft; -package org.apache.iotdb.cluster.client.sync; - -import org.apache.iotdb.cluster.rpc.thrift.Node; -import org.apache.iotdb.cluster.rpc.thrift.RaftService; -import org.apache.thrift.transport.TTransportException; - -import java.io.IOException; - -public interface SyncClientFactory { - - /** - * Get a client which will connect the given node and be cached in the given pool. - * - * @param node the cluster node the client will connect. - * @param pool the pool that will cache the client for reusing. - * @return - * @throws IOException - */ - RaftService.Client getSyncClient(Node node, SyncClientPool pool) throws TTransportException; - - default String nodeInfo(Node node) { - return node.toString(); - } -} +public interface MetaRaftServiceMBean {} diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java similarity index 53% copy from cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java copy to cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java index c34f1f3..f1316be 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientFactory.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java @@ -16,28 +16,27 @@ * specific language governing permissions and limitations * under the License. */ +package org.apache.iotdb.cluster.server.raft; -package org.apache.iotdb.cluster.client.sync; +import org.apache.thrift.protocol.TProtocol; +import org.apache.thrift.server.ServerContext; +import org.apache.thrift.server.TServerEventHandler; +import org.apache.thrift.transport.TTransport; -import org.apache.iotdb.cluster.rpc.thrift.Node; -import org.apache.iotdb.cluster.rpc.thrift.RaftService; -import org.apache.thrift.transport.TTransportException; +public class RaftServiceHandler implements TServerEventHandler { + @Override + public void preServe() {} -import java.io.IOException; - -public interface SyncClientFactory { + @Override + public ServerContext createContext(TProtocol tProtocol, TProtocol tProtocol1) { + return null; + } - /** - * Get a client which will connect the given node and be cached in the given pool. - * - * @param node the cluster node the client will connect. - * @param pool the pool that will cache the client for reusing. - * @return - * @throws IOException - */ - RaftService.Client getSyncClient(Node node, SyncClientPool pool) throws TTransportException; + @Override + public void deleteContext( + ServerContext serverContext, TProtocol tProtocol, TProtocol tProtocol1) {} - default String nodeInfo(Node node) { - return node.toString(); - } + @Override + public void processContext( + ServerContext serverContext, TTransport tTransport, TTransport tTransport1) {} } diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java index b2fb80c..b355766 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupServiceImpls.java @@ -41,6 +41,7 @@ import org.apache.iotdb.cluster.server.monitor.NodeReport.DataMemberReport; import org.apache.iotdb.cluster.utils.IOUtils; import org.apache.iotdb.db.utils.TestOnly; import org.apache.iotdb.service.rpc.thrift.TSStatus; + import org.apache.thrift.TException; import org.apache.thrift.async.AsyncMethodCallback; import org.apache.thrift.protocol.TProtocolFactory; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java index 7d20e96..d405046 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/service/MetaSyncService.java @@ -40,6 +40,7 @@ import org.apache.iotdb.cluster.server.Response; import org.apache.iotdb.cluster.server.member.MetaGroupMember; import org.apache.iotdb.cluster.utils.ClientUtils; import org.apache.iotdb.cluster.utils.ClusterUtils; + import org.apache.thrift.TException; import org.slf4j.Logger; import org.slf4j.LoggerFactory;
