java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.

Google Groups | Unknown author | 7 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Try to query against Kafka Topic and get "socket has likely been closed."

    Google Groups | 7 months ago | Unknown author
    java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.

    Root Cause Analysis

    1. java.io.EOFException

      Received -1 when reading from channel, socket has likely been closed.

      at kafka.utils.Utils$.read()
    2. Apache Kafka
      SimpleConsumer.send
      1. kafka.utils.Utils$.read(Utils.scala:381)
      2. kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
      3. kafka.network.Receive$class.readCompletely(Transmission.scala:56)
      4. kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
      5. kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
      6. kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
      7. kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
      8. kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:91)
      9. kafka.javaapi.consumer.SimpleConsumer.send(SimpleConsumer.scala:68)
      9 frames
    3. com.facebook.presto
      KafkaSplitManager.getSplits
      1. com.facebook.presto.kafka.KafkaSplitManager.getSplits(KafkaSplitManager.java:83)
      1 frame
    4. presto-main
      QueuedExecution.lambda$start$1
      1. com.facebook.presto.split.SplitManager.getSplits(SplitManager.java:45)
      2. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitTableScan(DistributedExecutionPlanner.java:112)
      3. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitTableScan(DistributedExecutionPlanner.java:92)
      4. com.facebook.presto.sql.planner.plan.TableScanNode.accept(TableScanNode.java:135)
      5. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitAggregation(DistributedExecutionPlanner.java:192)
      6. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitAggregation(DistributedExecutionPlanner.java:92)
      7. com.facebook.presto.sql.planner.plan.AggregationNode.accept(AggregationNode.java:189)
      8. com.facebook.presto.sql.planner.DistributedExecutionPlanner.plan(DistributedExecutionPlanner.java:78)
      9. com.facebook.presto.sql.planner.DistributedExecutionPlanner.plan(DistributedExecutionPlanner.java:83)
      10. com.facebook.presto.execution.SqlQueryExecution.planDistribution(SqlQueryExecution.java:303)
      11. com.facebook.presto.execution.SqlQueryExecution.start(SqlQueryExecution.java:226)
      12. com.facebook.presto.execution.QueuedExecution.lambda$start$1(QueuedExecution.java:62)
      12 frames
    5. Java RT
      Thread.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      3. java.lang.Thread.run(Thread.java:745)
      3 frames