File tree Expand file tree Collapse file tree 6 files changed +0
-20
lines changed
server/src/main/java/org/elasticsearch Expand file tree Collapse file tree 6 files changed +0
-20
lines changed Original file line number Diff line number Diff line change @@ -76,12 +76,6 @@ public class KeyStoreWrapper implements SecureSettings {
76
76
77
77
public static final String PROMPT = "Enter password for the elasticsearch keystore : " ;
78
78
79
- /** An identifier for the type of data that may be stored in a keystore entry. */
80
- private enum EntryType {
81
- STRING ,
82
- FILE
83
- }
84
-
85
79
/** An entry in the keystore. The bytes are opaque and interpreted based on the entry type. */
86
80
private static class Entry implements Writeable {
87
81
final byte [] bytes ;
Original file line number Diff line number Diff line change 32
32
*/
33
33
public class PrioritizedEsThreadPoolExecutor extends EsThreadPoolExecutor {
34
34
35
- private static final TimeValue NO_WAIT_TIME_VALUE = TimeValue .timeValueMillis (0 );
36
35
private final AtomicLong insertionOrder = new AtomicLong ();
37
36
private final Queue <Runnable > current = ConcurrentCollections .newQueue ();
38
37
private final ScheduledExecutorService timer ;
Original file line number Diff line number Diff line change @@ -230,7 +230,6 @@ private final class Visitor extends StoredFieldVisitor {
230
230
final LeafReader leafReader ;
231
231
final StoredFields storedFields ;
232
232
private int leftToVisit = 2 ;
233
- private final BytesRef spare = new BytesRef ();
234
233
private String routing ;
235
234
private String id ;
236
235
Original file line number Diff line number Diff line change 27
27
import org .elasticsearch .index .seqno .SequenceNumbers ;
28
28
import org .elasticsearch .index .shard .RemoveCorruptedShardDataCommand ;
29
29
import org .elasticsearch .index .shard .ShardPath ;
30
- import org .elasticsearch .xcontent .NamedXContentRegistry ;
31
30
32
31
import java .io .IOException ;
33
32
import java .nio .channels .FileChannel ;
46
45
public class TruncateTranslogAction {
47
46
48
47
protected static final Logger logger = LogManager .getLogger (TruncateTranslogAction .class );
49
- private final NamedXContentRegistry namedXContentRegistry ;
50
-
51
- public TruncateTranslogAction (NamedXContentRegistry namedXContentRegistry ) {
52
- this .namedXContentRegistry = namedXContentRegistry ;
53
- }
54
48
55
49
public static Tuple <RemoveCorruptedShardDataCommand .CleanStatus , String > getCleanStatus (
56
50
ShardPath shardPath ,
Original file line number Diff line number Diff line change 30
30
import org .elasticsearch .core .Nullable ;
31
31
import org .elasticsearch .core .Releasable ;
32
32
import org .elasticsearch .core .Releasables ;
33
- import org .elasticsearch .core .TimeValue ;
34
33
import org .elasticsearch .threadpool .ThreadPool ;
35
34
import org .elasticsearch .tracing .Tracer ;
36
35
import org .elasticsearch .transport .TaskTransportChannel ;
58
57
import java .util .function .Consumer ;
59
58
60
59
import static org .elasticsearch .core .Strings .format ;
61
- import static org .elasticsearch .core .TimeValue .timeValueMillis ;
62
60
import static org .elasticsearch .http .HttpTransportSettings .SETTING_HTTP_MAX_HEADER_SIZE ;
63
61
64
62
/**
@@ -68,8 +66,6 @@ public class TaskManager implements ClusterStateApplier {
68
66
69
67
private static final Logger logger = LogManager .getLogger (TaskManager .class );
70
68
71
- private static final TimeValue WAIT_FOR_COMPLETION_POLL = timeValueMillis (100 );
72
-
73
69
/** Rest headers that are copied to the task */
74
70
private final String [] taskHeaders ;
75
71
private final ThreadPool threadPool ;
Original file line number Diff line number Diff line change @@ -33,7 +33,6 @@ public abstract class RemoteClusterAware {
33
33
public static final String LOCAL_CLUSTER_GROUP_KEY = "" ;
34
34
35
35
protected final Settings settings ;
36
- private final ClusterNameExpressionResolver clusterNameResolver ;
37
36
private final String nodeName ;
38
37
private final boolean isRemoteClusterClientEnabled ;
39
38
@@ -43,7 +42,6 @@ public abstract class RemoteClusterAware {
43
42
*/
44
43
protected RemoteClusterAware (Settings settings ) {
45
44
this .settings = settings ;
46
- this .clusterNameResolver = new ClusterNameExpressionResolver ();
47
45
this .nodeName = Node .NODE_NAME_SETTING .get (settings );
48
46
this .isRemoteClusterClientEnabled = DiscoveryNode .isRemoteClusterClient (settings );
49
47
}
You can’t perform that action at this time.
0 commit comments