OperationNotSupportedException: операция не поддерживается для результата потоковой передачи (ResultSet)

Question

Учитывая этот код ниже:

if (resultSet == null) {
  pageNumber = 0;
  resultSet = getResultSet(db);
}
if (resultSet != null) {
  resultSetMetaData = resultSet.getMetaData();
  columnCount = resultSetMetaData.getColumnCount();
  resultSetArray = getResultSetAsList(resultSet, columnCount);
  rowCount = resultSetArray.size();
}

countTempSize = 0;
if (rowCount > 0 && resultSetArray != null && resultSetArray.size() > 0) {
  pageNumber = pageNumber + rowCount;
  ResultSet tempResultSet = getResultSet(db);
  if (resultSet != null && tempResultSet != null) {
    if (tempResultSetArray != null && tempResultSetArray.size() > 0) {
      tempResultSetArray.clear();
    }
    tempResultSetArray = getResultSetAsList(tempResultSet, columnCount);
    for (String columnName: timestampColumnName) {
      resultSet.last();
      tempResultSet.beforeFirst();
      int i = 0;
      while (tempResultSet.next() && resultSet.getString(columnName).toString().equals(tempResultSet.getString(columnName).toString())) {
        resultSetArray.add(tempResultSetArray.get(i));
        i++;
        countTempSize++;
      }
    }
  }
}

Следующая ошибка возникает при resultSet.last();:

ОШИБКА Не удалось запустить запрос для таблицы TimestampIncrementingTableQuerier {таблица = "mpdb". "Meta_eligibility", query = 'null', topicPrefix = 'Audit-mpdb-', incrementingColumn = '', timestampColumns = [made_on]}: {} (Io.confluent.connect.jdbc.source.JdbcSourceTask) com.mysql.jdbc.OperationNotSupportedException: операция не поддерживается для потоковых наборов результатов в com.mysql.jdbc.RowDataCursor.notSupported (RowDataCursor.java:452) в com.mysql.jdbc.RowDataCursor.beforeFirst (RowDataCursor.java:260) в com.mysql.jdbc.ResultSetImpl.first (ResultSetImpl.java:1129) в io.confluent.connect.jdbc.source.TableQuerier.maybeStartQuery (TableQuerier.java:130) в io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.maybeStartQuery (TimestampIncrementingTableQuerier.java:63) в io.confluent.connect.jdbc.source.JdbcSourceTask.poll (JdbcSourceTask.java:300) в org.apache.kafka.connect.runtime.WorkerSourceTask.execute (WorkerSourceTask.java:179) в org.apache.kafka.connect.runtime.WorkerTask.doRun (WorkerTask.java:170) в org.apache.kafka.connect.runtime.WorkerTask.run (WorkerTask.java:214) в java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:511) в java.util.concurrent.FutureTask.run (FutureTask.java:266) в java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142) в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:617) at java.lang.Thread.run (Thread.java:745)

это не работает. Как мне это написать?