backtype.storm.topology.FailedException: Received commit for different transaction attempt

GitHub | caiyifeng | 6 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

    使用OpaqueTridentKafkaSpout的错误,麻烦帮忙看看

    GitHub | 6 months ago | caiyifeng
    backtype.storm.topology.FailedException: Received commit for different transaction attempt
  2. 0

    Kafka+Jstorm,运行TridentTopology的时候遇到一个问题

    GitHub | 1 year ago | yamanko
    backtype.storm.topology.FailedException: Received commit for different transaction attempt

    Root Cause Analysis

    1. backtype.storm.topology.FailedException

      Received commit for different transaction attempt

      at storm.trident.spout.TridentSpoutExecutor.execute()
    2. storm.trident.spout
      TridentSpoutExecutor.execute
      1. storm.trident.spout.TridentSpoutExecutor.execute(TridentSpoutExecutor.java:73)[jstorm-core-2.1.1.jar:na]
      1 frame
    3. storm.trident.topology
      TridentBoltExecutor.execute
      1. storm.trident.topology.TridentBoltExecutor.execute(TridentBoltExecutor.java:315)[jstorm-core-2.1.1.jar:na]
      1 frame
    4. com.alibaba.jstorm
      BoltExecutors.onEvent
      1. com.alibaba.jstorm.task.execute.BoltExecutors.processTupleEvent(BoltExecutors.java:184)[jstorm-core-2.1.1.jar:na]
      2. com.alibaba.jstorm.task.execute.BoltExecutors.onEvent(BoltExecutors.java:158)[jstorm-core-2.1.1.jar:na]
      2 frames
    5. backtype.storm.utils
      DisruptorQueueImpl.consumeBatchWhenAvailable
      1. backtype.storm.utils.DisruptorQueueImpl.consumeBatchToCursor(DisruptorQueueImpl.java:193)[jstorm-core-2.1.1.jar:na]
      2. backtype.storm.utils.DisruptorQueueImpl.consumeBatchWhenAvailable(DisruptorQueueImpl.java:161)[jstorm-core-2.1.1.jar:na]
      2 frames
    6. com.alibaba.jstorm
      AsyncLoopRunnable.run
      1. com.alibaba.jstorm.task.execute.BoltExecutors.run(BoltExecutors.java:138)[jstorm-core-2.1.1.jar:na]
      2. com.alibaba.jstorm.callback.AsyncLoopRunnable.run(AsyncLoopRunnable.java:95)[jstorm-core-2.1.1.jar:na]
      2 frames
    7. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)[na:1.8.0_45]
      1 frame