private Void restart(
      AtomicLong writtenPointCounter, long targetPointNum, ExecutorService threadPool)
      throws InterruptedException, SQLException {
    while (writtenPointCounter.get() < targetPointNum) {
      Thread.sleep(10);
    }
    threadPool.shutdownNow();
    threadPool.awaitTermination(1, TimeUnit.MINUTES);

    try (Connection connection = EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);
        Statement statement = connection.createStatement()) {
      statement.execute("flush");
    }

    TestUtils.restartDataNodes();
    return null;
  }
Should delete this case after the deletion value filter feature be implemented
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java