java.sql.SQLException: Streaming result set com.mysql.jdbc.RowDataDynamic@27ce24aa is still active.

Error reading from database: java.sql.SQLException: Streaming result set com.mysql.jdbc.RowDataDynamic@27ce24aa is still active. No statements may be issued when any streaming result sets are open and in use on a given connection. Ensure that you have called .close() on any active streaming result sets before attempting more queries.
java.sql.SQLException: Streaming result set com.mysql.jdbc.RowDataDynamic@27ce24aa is still active. No statements may be issued when any streaming result sets are open and in use on a given connection. Ensure that you have called .close() on any active streaming result sets before attempting more queries.

sqoop export \
--connect $STAT_JDBC_CONNECT \
--username $JDBC_USERNAME \
--password $JDBC_PASSWORD \
--table $TABLE \
--update-mode allowinsert \
--driver com.mysql.jdbc.Driver \
--export-dir $SQOOP_HDFS_RESULT_DAY \
--columns stat_ds,command,answer,counts

  /**
    * 统计音箱型号分布情况
    *
    * @param dataFrame
    * @return
    */
  def echoModelDistributeStat(dataFrame: DataFrame, preDay: String): List[String] = {
    var numdf = dataFrame.groupBy("model").agg(count("model").as("model_count"))
    // 统计出总共的设备数
    var sumdf = numdf.groupBy().agg(sum("model_count"))
    // 计算设备型号的总数量
    var modelSum = sumdf.collect()(0)(0)
    // 计算出需要的的DF
    var modelInfo = numdf.select(numdf("model"), numdf("model_count"), (numdf("model_count") / modelSum * 100).as("model_percent"))
    modelInfo.registerTempTable("m")
    // 将日期转换为时间戳
    val timeStamp = TimeUtils.getTimeStamp(preDay + " " + Constant.TIME_ZERO)
    val timeDf = modelInfo.sqlContext.sql("select " + timeStamp + " as stat_ds,m.model,m.model_count,round(m.model_percent,2) as model_percent from m")
    // 将DF转成List[Row]的形式
    val list = timeDf.collect().toList
    // 将List[Row]转为List[String]
    val listStr = listRowConvertListStr(list)
    return listStr
  }