@Override
  public void setQueryTimeout(int seconds) throws SQLException {
    if (seconds > 0) {
      queryTimeout = seconds;
    } else {
      queryTimeout = DEFAULT_QUERY_TIMEOUT;
    }
    writeStatement.setQueryTimeout(queryTimeout);
    for (Statement readStatement : readStatements) {
      readStatement.setQueryTimeout(queryTimeout);
    }
  }
The implementation of {@link ClusterTestStatement} in cluster test.
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java