Skip to content

Commit 7594b8b

Browse files
committed
CR fixes
1 parent 717d483 commit 7594b8b

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

server/src/main/java/org/elasticsearch/tasks/TaskManager.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@
4949
import java.util.List;
5050
import java.util.Map;
5151
import java.util.Objects;
52-
import java.util.Optional;
5352
import java.util.Set;
5453
import java.util.concurrent.ConcurrentHashMap;
5554
import java.util.concurrent.CopyOnWriteArrayList;
@@ -82,7 +81,6 @@ public class TaskManager implements ClusterStateApplier {
8281

8382
private TaskResultsService taskResultsService;
8483

85-
// Used by tests that call register before setting the lastDiscoveryNodes.
8684
private final String nodeId;
8785
private DiscoveryNodes lastDiscoveryNodes = DiscoveryNodes.EMPTY_NODES;
8886

@@ -150,9 +148,8 @@ public Task register(String type, String action, TaskAwareRequest request, boole
150148
headers.put(key, httpHeader);
151149
}
152150
}
153-
String localNodeId = Optional.ofNullable(lastDiscoveryNodes.getLocalNodeId()).orElse(nodeId);
154151
Task task = request.createTask(
155-
new TaskId(localNodeId, taskIdGenerator.incrementAndGet()),
152+
new TaskId(nodeId, taskIdGenerator.incrementAndGet()),
156153
type,
157154
action,
158155
request.getParentTask(),

0 commit comments

Comments
 (0)