com.rethinkdb.gen.exc.ReqlDriverError: Can't write query because response pump is not running.

Google Groups | Andrew Xue | 2 months ago
  1. 0

    what is the expected behavior when a kafka connect task fails?

    Google Groups | 2 months ago | Andrew Xue
    com.rethinkdb.gen.exc.ReqlDriverError: Can't write query because response pump is not running.
  2. 0

    JAVA: Queries work when debugging, but NOT while running

    GitHub | 9 months ago | vinaysshenoy
    com.rethinkdb.gen.exc.ReqlDriverError: Can't write query because response pump is not running.

    Root Cause Analysis

    1. com.rethinkdb.gen.exc.ReqlDriverError

      Can't write query because response pump is not running.

      at com.rethinkdb.net.Connection.sendQuery()
    2. com.rethinkdb.net
      Connection.close
      1. com.rethinkdb.net.Connection.sendQuery(Connection.java:218)
      2. com.rethinkdb.net.Connection.runQuery(Connection.java:269)
      3. com.rethinkdb.net.Connection.runQuery(Connection.java:253)
      4. com.rethinkdb.net.Connection.runQuery(Connection.java:249)
      5. com.rethinkdb.net.Connection.noreplyWait(Connection.java:305)
      6. com.rethinkdb.net.Connection.close(Connection.java:152)
      6 frames
    3. com.datamountaineer.streamreactor
      ReThinkSinkTask$$anonfun$stop$1.apply
      1. com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkWriter.close(ReThinkWriter.scala:125)
      2. com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkTask$$anonfun$stop$1.apply(ReThinkSinkTask.scala:73)
      3. com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkTask$$anonfun$stop$1.apply(ReThinkSinkTask.scala:73)
      3 frames
    4. Scala
      Option.foreach
      1. scala.Option.foreach(Option.scala:257)
      1 frame
    5. com.datamountaineer.streamreactor
      ReThinkSinkTask.stop
      1. com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkTask.stop(ReThinkSinkTask.scala:73)
      1 frame
    6. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.close(WorkerSinkTask.java:126)
      2. org.apache.kafka.connect.runtime.WorkerTask.doClose(WorkerTask.java:121)
      3. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146)
      4. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      4 frames
    7. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      5. java.lang.Thread.run(Thread.java:745)
      5 frames