Matthias Pohl created FLINK-30940:
-------------------------------------
Summary: InterruptedException in ExecutorImplITCase which doesn't
fail the test
Key: FLINK-30940
URL: https://issues.apache.org/jira/browse/FLINK-30940
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.17.0
Reporter: Matthias Pohl
We're experiencing a test failure {{CliClientITCase.testSqlStatements}} which
might be caused by an {{InterruptedException}}:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=45828&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4&l=46490
{code}
Exception in thread "worker"
org.apache.flink.table.client.gateway.SqlExecutionException: Interrupted to
fetch results.
at
org.apache.flink.table.client.gateway.ExecutorImpl.lambda$fetchUtilResultsReady$4(ExecutorImpl.java:375)
at
org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:398)
at
org.apache.flink.table.client.gateway.ExecutorImpl.fetchUtilResultsReady(ExecutorImpl.java:368)
at
org.apache.flink.table.client.gateway.ExecutorImpl.executeStatement(ExecutorImpl.java:234)
at
org.apache.flink.table.client.gateway.ExecutorImplITCase.lambda$testInterruptExecution$7(ExecutorImplITCase.java:507)
at
org.apache.flink.table.client.gateway.ExecutorImplITCase.lambda$testInterrupting$12(ExecutorImplITCase.java:607)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.InterruptedException
at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:347)
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
at
org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:396)
... 5 more
Exception in thread "worker"
org.apache.flink.table.client.gateway.SqlExecutionException: Interrupted to
fetch results.
at
org.apache.flink.table.client.gateway.ExecutorImpl.lambda$fetchUtilResultsReady$4(ExecutorImpl.java:375)
at
org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:398)
at
org.apache.flink.table.client.gateway.ExecutorImpl.fetchUtilResultsReady(ExecutorImpl.java:368)
at
org.apache.flink.table.client.gateway.ExecutorImpl.executeStatement(ExecutorImpl.java:234)
at
org.apache.flink.table.client.gateway.ExecutorImplITCase.lambda$testInterruptFetching$8(ExecutorImplITCase.java:515)
at
org.apache.flink.table.client.gateway.ExecutorImplITCase.lambda$testInterrupting$12(ExecutorImplITCase.java:607)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.InterruptedException
at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:347)
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
at
org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:396)
... 5 more
Exception in thread "worker"
org.apache.flink.table.client.gateway.SqlExecutionException: Interrupted to get
response.
at
org.apache.flink.table.client.gateway.ExecutorImpl.lambda$executeStatement$2(ExecutorImpl.java:228)
at
org.apache.flink.table.client.gateway.ExecutorImpl.getResponse(ExecutorImpl.java:429)
at
org.apache.flink.table.client.gateway.ExecutorImpl.executeStatement(ExecutorImpl.java:210)
at
org.apache.flink.table.client.gateway.ExecutorImplITCase.lambda$testInterruptSubmitting$6(ExecutorImplITCase.java:502)
at
org.apache.flink.table.client.gateway.ExecutorImplITCase.lambda$testInterrupting$12(ExecutorImplITCase.java:607)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.InterruptedException
at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:347)
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
at
org.apache.flink.table.client.gateway.ExecutorImpl.getResponse(ExecutorImpl.java:424)
... 4 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
