Uploaded image for project: 'Eagle (Retired)'
  1. Eagle (Retired)
  2. EAGLE-491

AlertPublisherImpl dedup throws exception when dedup column is not configured

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Trivial
    • Resolution: Fixed
    • v0.5.0
    • v0.5.0
    • None
    • None

    Description

      2016-08-22 14:51:49,728 WARN [alertBolt1-evaluator_stage1] runner.AlertBolt[127]: Spec Version [spec_version_1471902692329] of AlertBolt is newer than Stream Event Version [null]!
      2016-08-22 14:51:49,729 ERROR [Thread-45-alertPublishBolt] impl.AlertPublisherImpl[80]: Fail invoking publisher's onAlert, continue
      java.lang.NullPointerException
      at org.apache.eagle.alert.engine.publisher.impl.DefaultDeduplicator.dedup(DefaultDeduplicator.java:114)
      at org.apache.eagle.alert.engine.publisher.impl.AbstractPublishPlugin.dedup(AbstractPublishPlugin.java:68)
      at org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher.onAlert(AlertEmailPublisher.java:67)
      at org.apache.eagle.alert.engine.publisher.impl.AlertPublisherImpl.notifyAlert(AlertPublisherImpl.java:78)
      at org.apache.eagle.alert.engine.publisher.impl.AlertPublisherImpl.nextEvent(AlertPublisherImpl.java:65)
      at org.apache.eagle.alert.engine.runner.AlertPublisherBolt.execute(AlertPublisherBolt.java:68)
      at backtype.storm.daemon.executor$fn_3441$tuple_action_fn_3443.invoke(executor.clj:633)
      at backtype.storm.daemon.executor$mk_task_receiver$fn__3364.invoke(executor.clj:401)
      at backtype.storm.disruptor$clojure_handler$reify__1447.onEvent(disruptor.clj:58)
      at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125)
      at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99)
      at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80)
      at backtype.storm.daemon.executor$fn_3441$fn3453$fn_3500.invoke(executor.clj:748)
      at backtype.storm.util$async_loop$fn__464.invoke(util.clj:463)
      at clojure.lang.AFn.run(AFn.java:24)
      at java.lang.Thread.run(Thread.java:745)

      Attachments

        Issue Links

          Activity

            People

              mizeng87 Zeng, Bryant
              yonzhang2012 Edward Zhang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: