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>

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 (file)
--- 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);
                     }
                 }