Skip to content

Commit a38c29f

Browse files
committed
Fix precedence
1 parent ed10eac commit a38c29f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/src/main/java/org/elasticsearch/threadpool/EsExecutorServiceDecorator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, Ti
146146
public void execute(Runnable command) {
147147
final Runnable wrappedRunnable = command != WORKER_PROBE ? wrapRunnable(command) : WORKER_PROBE;
148148
try {
149-
if (rejectAfterShutdown && shutdownRequested.get() || delegate.isShutdown()) {
149+
if (rejectAfterShutdown && (shutdownRequested.get() || delegate.isShutdown())) {
150150
throw new EsRejectedExecutionException("executor has been shutdown", delegate.isShutdown());
151151
}
152152
// Increment outstanding task count

0 commit comments

Comments
 (0)