Skip to content
Permalink
Browse files
[IOTDB-1821] IT fails on IoTDBContinuousQueryIT caused by connection …
…broken (#4118)
  • Loading branch information
SteveYurongSu committed Oct 12, 2021
1 parent 4bae008 commit 51a02f7a48ffdf1c4ff48d5ea1e4fb6ad3b4ff63
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
@@ -19,9 +19,7 @@
under the License.
-->
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.iotdb</groupId>
@@ -85,9 +85,6 @@ private void startDataGenerator() {
private void stopDataGenerator() throws InterruptedException {
dataGenerator.interrupt();
dataGenerator.join();
if (exception != null) {
fail(exception.getMessage());
}
}

private final String[] timeSeriesArray = {
@@ -322,6 +319,12 @@ private void checkCQExecutionResult(
long groupByInterval,
int level)
throws SQLException, InterruptedException {
// IOTDB-1821
// ignore the check when the background data generation thread's connection is broken
if (exception != null) {
return;
}

final long expectedSize = (duration / everyInterval + 1) * (forInterval / groupByInterval);
long waitSeconds = 0;
List<Pair<Long, String>> result;

0 comments on commit 51a02f7

Please sign in to comment.