summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCraig Bryant <craig.bryant@hpe.com>2018-01-18 10:47:30 -0700
committerCraig Bryant <craig.bryant@hpe.com>2018-01-18 10:47:30 -0700
commit106088887a05936ef3d94d1fc9759119dacaac8f (patch)
treeee5c0eb7303756ceb0a598399111c8d5857024cd
parentbe22e54fd792fb7ddcc4c8a145a5c173b7c34245 (diff)
Log as error failure to send to Kafka
Exception on failure to send to Kafka was only being logged at the debug level. Increased to error level as this is a major failure in the Threshold Engine functionality Change-Id: I131d6d7a20cd0e907334cf5d0ff6fac342e8f320
Notes
Notes (review): Code-Review+1: James Gu <jgu@suse.com> Code-Review+1: Andrea Adams <aadams@hpe.com> Code-Review+1: Ryan Brandt <ryan.brandt@hpe.com> Code-Review+1: Tim Buckley <timothy.jas.buckley@hpe.com> Code-Review+2: Joe Keen <joe.keen@hpe.com> Workflow+1: Joe Keen <joe.keen@hpe.com> Verified+2: Zuul Submitted-by: Zuul Submitted-at: Thu, 18 Jan 2018 19:47:01 +0000 Reviewed-on: https://review.openstack.org/535425 Project: openstack/monasca-thresh Branch: refs/heads/master
-rw-r--r--thresh/src/main/java/monasca/thresh/infrastructure/thresholding/AlarmThresholdingBolt.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/thresh/src/main/java/monasca/thresh/infrastructure/thresholding/AlarmThresholdingBolt.java b/thresh/src/main/java/monasca/thresh/infrastructure/thresholding/AlarmThresholdingBolt.java
index 47c79a7..56a2fc2 100644
--- a/thresh/src/main/java/monasca/thresh/infrastructure/thresholding/AlarmThresholdingBolt.java
+++ b/thresh/src/main/java/monasca/thresh/infrastructure/thresholding/AlarmThresholdingBolt.java
@@ -1,5 +1,5 @@
1/* 1/*
2 * (C) Copyright 2014-2016 Hewlett Packard Enterprise Development LP 2 * (C) Copyright 2014-2016,2018 Hewlett Packard Enterprise Development LP
3 * 3 *
4 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License. 5 * you may not use this file except in compliance with the License.
@@ -241,7 +241,7 @@ public class AlarmThresholdingBolt extends BaseRichBolt {
241 try { 241 try {
242 alarmEventForwarder.send(Serialization.toJson(event)); 242 alarmEventForwarder.send(Serialization.toJson(event));
243 } catch (Exception ignore) { 243 } catch (Exception ignore) {
244 logger.debug("Failure sending alarm", ignore); 244 logger.error("Failure sending alarm", ignore);
245 } 245 }
246 } 246 }
247 247