java.lang.IllegalStateException: Sent message with ID -7052628355821213635, received -3092149936855596248. 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 -7052628355821213635, received -3092149936855596248. ID must be the same.

    Root Cause Analysis

    1. java.lang.IllegalStateException

      Sent message with ID -7052628355821213635, received -3092149936855596248. 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.pingRequest(TcpTransport.scala:66)
      6. com.bwsw.tstreams.coordination.producer.PeerAgent$$anonfun$updateMaster$2.apply(PeerAgent.scala:224)
      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
      Producer.newTransaction
      1. com.bwsw.tstreams.coordination.producer.PeerAgent.updateMaster(PeerAgent.scala:198)
      2. com.bwsw.tstreams.coordination.producer.PeerAgent$$anonfun$generateNewTransaction$1.apply(PeerAgent.scala:321)
      3. com.bwsw.tstreams.coordination.producer.PeerAgent$$anonfun$generateNewTransaction$1.apply(PeerAgent.scala:292)
      4. com.bwsw.tstreams.common.LockUtil$.withLockOrDieDo(LockUtil.scala:49)
      5. com.bwsw.tstreams.coordination.producer.PeerAgent.generateNewTransaction(PeerAgent.scala:292)
      6. com.bwsw.tstreams.agents.producer.Producer.newTransaction(Producer.scala:166)
      6 frames
    5. agents.integration
      ManyProducersStreamingInManyPartitionsAndConsumerWithCheckpointsTest$$anonfun$1$$anonfun$4$$anon$1.run
      1. agents.integration.ManyProducersStreamingInManyPartitionsAndConsumerWithCheckpointsTest$$anonfun$1$$anonfun$4$$anon$1.run(ManyProducersStreamingInManyPartitionsAndConsumerWithCheckpointsTest.scala:46)
      1 frame
    6. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame