Skip to content

Commit cf7b987

Browse files
committed
smaller
1 parent abde0fe commit cf7b987

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ClusterComputeHandler.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,8 +111,7 @@ void startComputeOnRemoteCluster(
111111
} else {
112112
try {
113113
groupTask = computeService.createGroupTask(rootTask, () -> "compute group: cluster [" + clusterAlias + "]");
114-
} catch (Exception e) {
115-
assert e instanceof TaskCancelledException : new AssertionError(e);
114+
} catch (TaskCancelledException e) {
116115
l.onFailure(e);
117116
return;
118117
}

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/DataNodeComputeHandler.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,8 +135,7 @@ protected void sendRequest(
135135
parentTask,
136136
() -> "compute group: data-node [" + node.getName() + "], " + shardIds + " [" + shardIds + "]"
137137
);
138-
} catch (Exception e) {
139-
assert e instanceof TaskCancelledException : new AssertionError(e);
138+
} catch (TaskCancelledException e) {
140139
l.onFailure(e);
141140
return;
142141
}

0 commit comments

Comments
 (0)