Improve normalization close error message

airbyte-commons-worker/src/main/java/io/airbyte/workers/normalization/DefaultNormalizationRunner.java

@@ -194,10 +194,20 @@ public void close() throws Exception {
       return;
     }
 
-    LOGGER.debug("Closing normalization process");
+    LOGGER.debug("Terminating normalization process {}...", process.pid());
     WorkerUtils.gentleClose(process, 1, TimeUnit.MINUTES);
-    if (process.isAlive() || process.exitValue() != 0) {
-      throw new WorkerException("Normalization process wasn't successful");
+
+    /*
+     * After attempting to close the process check the following:
+     *
+     * Did the process actually terminate? If "yes", did it do so nominally?
+     */
+    if (process.isAlive()) {
+      throw new WorkerException("Normalization process " + process.pid() + " did not terminate after 1 minute.");
+    } else if (process.exitValue() != 0) {
+      throw new WorkerException("Normalization process " + process.pid() + " did not terminate normally (exit code: " + process.exitValue() + ")");
+    } else {
+      LOGGER.debug("Normalization process {} successfully terminated.", process.pid());
     }
   }
 

airbyte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

@@ -9,8 +9,6 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Preconditions;
-import io.airbyte.commons.exceptions.ConfigErrorException;
-import io.airbyte.commons.exceptions.ConnectionErrorException;
 import io.airbyte.commons.io.IOs;
 import io.airbyte.commons.json.Jsons;
 import io.airbyte.commons.lang.Exceptions.Procedure;