chore: refactor some code quality

Author: fhussonnois

connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/source/FilePulseSourceTask.java

@@ -245,11 +245,14 @@ public List<SourceRecord> poll() throws InterruptedException {
                 if (!isTaskRunning()) continue;
                 return results;
             }
-        } catch (final Throwable t) {
-            // This task has failed, so close any resources (maybe reopened if needed) before throwing
+        } catch (final Exception e) {
+            if (e instanceof InterruptedException) {
+                Thread.currentThread().interrupt();
+            }
+            // This task has failed, so close any resources before throwing
             LOG.error("This task has failed due to uncaught error and will be stopped.");
             closeResources();
-            throw t;
+            throw e;
         }
         // Only in case of shutdown
         closeResources();

connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/source/FileSystemMonitorThread.java

@@ -108,7 +108,9 @@ void shutdown(final long timeoutMs) {
         LOG.info("Shutting down thread monitoring filesystem.");
         this.shutdownLatch.countDown();
         try {
-            this.waitingLatch.await(timeoutMs, TimeUnit.MILLISECONDS);
+            if (waitingLatch.await(timeoutMs, TimeUnit.MILLISECONDS)) {
+                LOG.debug("Timeout reached before completing thread shutdown");
+            }
         } catch (InterruptedException ignore) {
             LOG.error("Timeout : scan loop is not terminated yet.");
             Thread.currentThread().interrupt();