summaryrefslogtreecommitdiffstats
path: root/dcae-analytics-cdap-plugins/src/main/java/org
diff options
context:
space:
mode:
authorSnigdha Sucharita Patra <sp00503415@techmahindra.com>2018-02-14 12:50:54 +0530
committerSnigdha Sucharita Patra <sp00503415@techmahindra.com>2018-02-14 12:50:54 +0530
commit1a0595e1953c7b745186f7c534f8e348428ac74a (patch)
treef41f63847381fea1465cb2fa8d0494a84bfd3b1a /dcae-analytics-cdap-plugins/src/main/java/org
parented8a2b2029f2beb0d45586b32dfed7895fce4f6e (diff)
sonar critical issue
Either re-interrupt this method or rethrow the InterruptedException Sonar Link: https://sonar.onap.org/project/issues?assignees=Snigdha503415&id=org.onap.dcaegen2.analytics.tca%3Adcae-analytics&open=AWFSdub6of9FJ6jfXJfc&resolved=false&severities=CRITICAL Location: src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/DMaaPMRReceiver.java Line No-79 Change-Id: Ia7b0aacd7a1035bf1ff4cee551715df737f58d9d Issue-ID: DCAEGEN2-334 Signed-off-by: Snigdha Sucharita Patra <sp00503415@techmahindra.com>
Diffstat (limited to 'dcae-analytics-cdap-plugins/src/main/java/org')
-rw-r--r--dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/DMaaPMRReceiver.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/DMaaPMRReceiver.java b/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/DMaaPMRReceiver.java
index 593d5d1..1c291af 100644
--- a/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/DMaaPMRReceiver.java
+++ b/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/DMaaPMRReceiver.java
@@ -79,6 +79,7 @@ public class DMaaPMRReceiver extends Receiver<StructuredRecord> {
} catch (InterruptedException e) {
final String errorMessage = String.format(
"Interrupted Exception while DMaaP MR Receiver sleeping polling interval: %s", e);
+ Thread.currentThread().interrupt();
throw new DCAEAnalyticsRuntimeException(errorMessage, LOG, e);
}
}