From f65ce1ce58b59f9265f2796c6ff70e4e57a50e57 Mon Sep 17 00:00:00 2001 From: jdpgrailsdev Date: Fri, 2 Dec 2022 14:02:03 -0500 Subject: [PATCH] Remove use of unimplemented pid() method --- .../workers/normalization/DefaultNormalizationRunner.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/airbyte-commons-worker/src/main/java/io/airbyte/workers/normalization/DefaultNormalizationRunner.java b/airbyte-commons-worker/src/main/java/io/airbyte/workers/normalization/DefaultNormalizationRunner.java index 0b4bc2913cad..786c6a5ea072 100644 --- a/airbyte-commons-worker/src/main/java/io/airbyte/workers/normalization/DefaultNormalizationRunner.java +++ b/airbyte-commons-worker/src/main/java/io/airbyte/workers/normalization/DefaultNormalizationRunner.java @@ -201,7 +201,7 @@ public void close() throws Exception { return; } - LOGGER.info("Terminating normalization process {}...", process.pid()); + LOGGER.info("Terminating normalization process..."); WorkerUtils.gentleClose(process, 1, TimeUnit.MINUTES); /* @@ -210,11 +210,11 @@ public void close() throws Exception { * 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."); + throw new WorkerException("Normalization process 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() + ")"); + throw new WorkerException("Normalization process did not terminate normally (exit code: " + process.exitValue() + ")"); } else { - LOGGER.info("Normalization process {} successfully terminated.", process.pid()); + LOGGER.info("Normalization process successfully terminated."); } }