|
18 | 18 |
|
19 | 19 | package org.apache.hadoop.hdds.scm; |
20 | 20 |
|
21 | | -import com.google.common.annotations.VisibleForTesting; |
22 | | -import com.google.common.base.Preconditions; |
| 21 | +import java.io.IOException; |
| 22 | +import java.util.Collection; |
| 23 | +import java.util.List; |
| 24 | +import java.util.Objects; |
| 25 | +import java.util.OptionalLong; |
| 26 | +import java.util.UUID; |
| 27 | +import java.util.concurrent.CompletableFuture; |
| 28 | +import java.util.concurrent.CompletionException; |
| 29 | +import java.util.concurrent.ConcurrentHashMap; |
| 30 | +import java.util.concurrent.ExecutionException; |
| 31 | +import java.util.concurrent.TimeUnit; |
| 32 | +import java.util.concurrent.TimeoutException; |
| 33 | +import java.util.concurrent.atomic.AtomicReference; |
| 34 | +import java.util.stream.Collectors; |
23 | 35 |
|
| 36 | +import org.apache.hadoop.conf.Configuration; |
24 | 37 | import org.apache.hadoop.hdds.HddsUtils; |
25 | 38 | import org.apache.hadoop.hdds.protocol.DatanodeDetails; |
26 | 39 | import org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos; |
| 40 | +import org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandRequestProto; |
| 41 | +import org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandResponseProto; |
| 42 | +import org.apache.hadoop.hdds.protocol.proto.HddsProtos; |
| 43 | +import org.apache.hadoop.hdds.scm.client.HddsClientUtils; |
| 44 | +import org.apache.hadoop.hdds.scm.pipeline.Pipeline; |
27 | 45 | import org.apache.hadoop.hdds.security.x509.SecurityConfig; |
28 | | - |
29 | | -import io.opentracing.Scope; |
30 | | -import io.opentracing.util.GlobalTracer; |
| 46 | +import org.apache.hadoop.hdds.tracing.TracingUtil; |
31 | 47 | import org.apache.hadoop.util.Time; |
| 48 | +import org.apache.ratis.RatisHelper; |
| 49 | +import org.apache.ratis.client.RaftClient; |
32 | 50 | import org.apache.ratis.grpc.GrpcTlsConfig; |
33 | 51 | import org.apache.ratis.proto.RaftProtos; |
34 | 52 | import org.apache.ratis.protocol.GroupMismatchException; |
| 53 | +import org.apache.ratis.protocol.RaftClientReply; |
35 | 54 | import org.apache.ratis.protocol.RaftException; |
36 | | -import org.apache.ratis.protocol.RaftRetryFailureException; |
37 | 55 | import org.apache.ratis.retry.RetryPolicy; |
38 | | -import org.apache.ratis.thirdparty.com.google.protobuf |
39 | | - .InvalidProtocolBufferException; |
40 | | -import org.apache.hadoop.conf.Configuration; |
41 | | -import org.apache.hadoop.hdds.scm.client.HddsClientUtils; |
42 | | -import org.apache.hadoop.hdds.scm.pipeline.Pipeline; |
43 | | -import org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos |
44 | | - .ContainerCommandRequestProto; |
45 | | -import org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos |
46 | | - .ContainerCommandResponseProto; |
47 | | -import org.apache.hadoop.hdds.protocol.proto.HddsProtos; |
48 | | -import org.apache.hadoop.hdds.tracing.TracingUtil; |
49 | | - |
50 | | -import org.apache.ratis.RatisHelper; |
51 | | -import org.apache.ratis.client.RaftClient; |
52 | | -import org.apache.ratis.protocol.RaftClientReply; |
53 | 56 | import org.apache.ratis.rpc.RpcType; |
54 | 57 | import org.apache.ratis.rpc.SupportedRpcType; |
55 | 58 | import org.apache.ratis.thirdparty.com.google.protobuf.ByteString; |
| 59 | +import org.apache.ratis.thirdparty.com.google.protobuf.InvalidProtocolBufferException; |
56 | 60 | import org.apache.ratis.util.TimeDuration; |
57 | 61 | import org.slf4j.Logger; |
58 | 62 | import org.slf4j.LoggerFactory; |
59 | 63 |
|
60 | | -import java.io.IOException; |
61 | | -import java.util.*; |
62 | | -import java.util.concurrent.CompletableFuture; |
63 | | -import java.util.concurrent.CompletionException; |
64 | | -import java.util.concurrent.TimeUnit; |
65 | | -import java.util.concurrent.ExecutionException; |
66 | | -import java.util.concurrent.TimeoutException; |
67 | | -import java.util.concurrent.atomic.AtomicReference; |
68 | | -import java.util.concurrent.ConcurrentHashMap; |
69 | | -import java.util.stream.Collectors; |
| 64 | +import com.google.common.annotations.VisibleForTesting; |
| 65 | +import com.google.common.base.Preconditions; |
| 66 | + |
| 67 | +import io.opentracing.Scope; |
| 68 | +import io.opentracing.util.GlobalTracer; |
70 | 69 |
|
71 | 70 | /** |
72 | 71 | * An abstract implementation of {@link XceiverClientSpi} using Ratis. |
|
0 commit comments