[geomesa-dev] [JIRA] (GEOMESA-3119) The order of the results of multiple

["hujian (JIRA)" <jira@xxxxxxxxxxxxxxxxxxxxx>]

Title: Message Title

hujian created an issue

GeoMesa / GEOMESA-3119

The order of the results of multiple queries by geomesa is inconsistent

Issue Type:	Bug
Affects Versions:	3.0.0, 3.0.1, 3.2.0, 3.1.1, 3.1.2
Assignee:	Unassigned
Components:	HBase
Created:	08/Aug/21 11:43 PM
Priority:	Major
Reporter:	hujian

In geomesa 3.x, multi-threaded queries cannot guarantee the consistency of the result order.

SourceCode:

private class SingleThreadScan extends Runnable {
    override def run(): Unit = {
      try {
        var range = inQueue.poll()
        while (range != null) {
          val result = scan(range)
          try {
            while (result.hasNext) {
              val r = result.next
              while (!outQueue.offer(r, 100, TimeUnit.MILLISECONDS)) {
                if (closed) {
                  return
                }
              }
            }
          } finally {
            result.close()
          }
          range = inQueue.poll()
        }
      } catch {
        case NonFatal(e) =>
          AbstractBatchScan.this.synchronized {
            if (error == null) { error = e } else { error.addSuppressed(e) }
          }
          close()
      } finally {
        latch.countDown()
      }
    }
  }

Add Comment

Get Jira notifications on your phone! Download the Jira Cloud app for Android or iOS
This message was sent by Atlassian Jira (v1001.0.0-SNAPSHOT#100172-sha1:1c5630e)