X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=dcae-analytics-cdap-tca%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdcae%2Fapod%2Fanalytics%2Fcdap%2Ftca%2Fworker%2FBaseTCADMaaPMRWorker.java;fp=dcae-analytics-cdap-tca%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdcae%2Fapod%2Fanalytics%2Fcdap%2Ftca%2Fworker%2FBaseTCADMaaPMRWorker.java;h=7681f5b85cfe297cf120d2533268d146b7ce923c;hb=7904a8783b91aae406aa96949c9d28f9948110e9;hp=f9deac82fa6d23e0a775d3e0255ebfb2024e407b;hpb=c346dfea14d98957d37f4615b03d0d47c281c7c2;p=dcaegen2%2Fanalytics%2Ftca.git

diff --git a/dcae-analytics-cdap-tca/src/main/java/org/onap/dcae/apod/analytics/cdap/tca/worker/BaseTCADMaaPMRWorker.java b/dcae-analytics-cdap-tca/src/main/java/org/onap/dcae/apod/analytics/cdap/tca/worker/BaseTCADMaaPMRWorker.java
index f9deac8..7681f5b 100644
--- a/dcae-analytics-cdap-tca/src/main/java/org/onap/dcae/apod/analytics/cdap/tca/worker/BaseTCADMaaPMRWorker.java
+++ b/dcae-analytics-cdap-tca/src/main/java/org/onap/dcae/apod/analytics/cdap/tca/worker/BaseTCADMaaPMRWorker.java
@@ -83,6 +83,7 @@ public abstract class BaseTCADMaaPMRWorker extends AbstractWorker {
                 final String errorMessage =
                         format("Error while checking TCA DMaaP MR Scheduler worker status name: %s, error: %s",
                                 schedulerName, e);
+                Thread.currentThread().interrupt();
                 throw new DCAEAnalyticsRuntimeException(errorMessage, LOG, e);
             }
         }