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

GitHub | caiyifeng | 3 months ago
  1. 0

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

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

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

    GitHub | 11 months 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