diff options
| author | lijinyang <[email protected]> | 2024-06-17 11:36:20 +0800 |
|---|---|---|
| committer | lijinyang <[email protected]> | 2024-06-17 11:36:20 +0800 |
| commit | 8c1228ae1d1d1ca8690b1ce028b3bff4cf84795b (patch) | |
| tree | 2e240dcbbae12ee053be52fe7f8aa6782981bd77 | |
| parent | ac267273f2ac628bcedc8a023f479e815a8f80bf (diff) | |
| -rw-r--r-- | src/test/java/com/mesa/reportservice/service/impl/QueryGatewayServiceImplTest.java | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/src/test/java/com/mesa/reportservice/service/impl/QueryGatewayServiceImplTest.java b/src/test/java/com/mesa/reportservice/service/impl/QueryGatewayServiceImplTest.java index 7eef27d..aad4e29 100644 --- a/src/test/java/com/mesa/reportservice/service/impl/QueryGatewayServiceImplTest.java +++ b/src/test/java/com/mesa/reportservice/service/impl/QueryGatewayServiceImplTest.java @@ -116,10 +116,6 @@ public class QueryGatewayServiceImplTest extends ReportServiceApplicationTests { Thread thread = new Thread(() -> { try { HttpResult result = queryGatewayService.queryJob(sql); - logger.info(result.getBody()); - if(!result.getBody().contains("Error in SQL execution: Code: 394. DB::Exception: Query was cancelled. (QUERY_WAS_CANCELLED)")) { - throw new SQSException("Job not cancelled", ERROR.getCode()); - } } catch (IOException e) { e.printStackTrace(); } @@ -131,7 +127,6 @@ public class QueryGatewayServiceImplTest extends ReportServiceApplicationTests { Assert.assertTrue(process.getBody().contains("elapsed")); HttpResult httpResult = queryGatewayService.deleteJob(queryId); Assert.assertTrue(httpResult.getCode() == HttpStatus.OK.value()); - thread.checkAccess(); thread.join(); } catch (InterruptedException e) { e.printStackTrace(); |
