File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -432,7 +432,9 @@ protected void doRun() throws Exception {
432
432
}
433
433
Exception failure = expectThrows (Exception .class , () -> future .actionGet ().close ());
434
434
EsqlTestUtils .assertEsqlFailure (failure );
435
- assertThat (failure .getMessage (), containsString ("failed to fetch pages" ));
435
+ Throwable cause = ExceptionsHelper .unwrap (failure , IOException .class );
436
+ assertNotNull (cause );
437
+ assertThat (cause .getMessage (), containsString ("failed to fetch pages" ));
436
438
// If we proceed without waiting for pages, we might cancel the main request before starting the data-node request.
437
439
// As a result, the exchange sinks on data-nodes won't be removed until the inactive_timeout elapses, which is
438
440
// longer than the assertBusy timeout.
You can’t perform that action at this time.
0 commit comments