java.lang.IllegalStateException: Sent message with ID -3092149936855596248, received -7052628355821213635. ID must be the same.

GitHub | bwsw | 6 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    New master ownership model

    GitHub | 6 months ago | bwsw
    java.lang.IllegalStateException: Sent message with ID -3092149936855596248, received -7052628355821213635. ID must be the same.

    Root Cause Analysis

    1. java.lang.IllegalStateException

      Sent message with ID -3092149936855596248, received -7052628355821213635. ID must be the same.

      at com.bwsw.tstreams.coordination.client.CommunicationClient$$anonfun$sendAndWaitResponse$1.apply()
    2. com.bwsw.tstreams
      PeerAgent$$anonfun$updateMaster$2.apply
      1. com.bwsw.tstreams.coordination.client.CommunicationClient$$anonfun$sendAndWaitResponse$1.apply(CommunicationClient.scala:97)
      2. com.bwsw.tstreams.coordination.client.CommunicationClient$$anonfun$sendAndWaitResponse$1.apply(CommunicationClient.scala:92)
      3. com.bwsw.tstreams.coordination.client.CommunicationClient.withRetryDo(CommunicationClient.scala:75)
      4. com.bwsw.tstreams.coordination.client.CommunicationClient.sendAndWaitResponse(CommunicationClient.scala:92)
      5. com.bwsw.tstreams.coordination.client.TcpTransport.deleteMasterRequest(TcpTransport.scala:52)
      6. com.bwsw.tstreams.coordination.producer.PeerAgent$$anonfun$updateMaster$2.apply(PeerAgent.scala:200)
      7. com.bwsw.tstreams.coordination.producer.PeerAgent$$anonfun$updateMaster$2.apply(PeerAgent.scala:198)
      7 frames
    3. Scala
      Option.fold
      1. scala.Option.fold(Option.scala:158)
      1 frame
    4. com.bwsw.tstreams
      PeerAgent$$anon$2.run
      1. com.bwsw.tstreams.coordination.producer.PeerAgent.updateMaster(PeerAgent.scala:198)
      2. com.bwsw.tstreams.coordination.producer.PeerAgent$$anon$2.run(PeerAgent.scala:125)
      2 frames
    5. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame