Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-2403

Fix KafkaBolt test failure: tick tuple should not be acked

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • 2.0.0, 1.1.0, 1.0.4
    • 2.0.0, 1.1.0, 1.0.4
    • storm-kafka
    • None

    Description

      From STORM-2387, I changed KafkaBolt to make sure it doesn't ack tick tuples.
      (Tick tuples are generated from each executor and don't trigger ACK_INIT so actually it should not be acked. Acker will keep them and remove some for message timeout so not a big deal though.)

      But I forgot to fix unit test for that, and also missed to check test result. This issue is for making quick fix for that.

      Attachments

        Issue Links

          Activity

            People

              kabhwan Jungtaek Lim
              kabhwan Jungtaek Lim
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 0.5h
                  0.5h