Improve normalization close error message

[jdpgrailsdev]

What

• Improve the error message when the normalization process fails

How

• Separate the two cases that cause an error when attempting to close the normalization process
• Include more details in the error message

Recommended reading order

1. DefaultNormalizationRunner.java

Tests

• All existing tests pass
• Project builds successfully locally

[Aggiekev]

I believe this merge is causing my Connections to fail during normalization. The error message isn't descriptive in the logs but this is the only merge that dealt with normalization in the last release which is where my Connections are failing. They fail at different points in the transformation for every single connection. My guess is that it is related to the waiting for one minute to throw the error?

[natalyjazzviolin]

@edgao looks like this is causing failures for an OSS user - @Aggiekev . Their instance is K8 on GKE, logs attached below.
f62c3bbc_ade5_44cf_b1ba_96e850184f73_logs_1415_txt (1).txt

[edgao]

@jdpgrailsdev do you recognize what's happening in that sync? It looks like normalization terminates cleanly (2022-12-06 05:50:16 normalization > Completed successfully) but DefaultNormalizationWorker thinks it failed:

2022-12-06 05:50:17 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Normalization Failed.
        at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:103) ~[io.airbyte-airbyte-commons-worker-0.40.23.jar:?]
        at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:34) ~[io.airbyte-airbyte-commons-worker-0.40.23.jar:?]
        at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.23.jar:?]
        at java.lang.Thread.run(Thread.java:1589) ~[?:?]

[jdpgrailsdev]

@jdpgrailsdev do you recognize what's happening in that sync? It looks like normalization terminates cleanly (2022-12-06 05:50:16 normalization > Completed successfully) but DefaultNormalizationWorker thinks it failed:

2022-12-06 05:50:17 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Normalization Failed.
        at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:103) ~[io.airbyte-airbyte-commons-worker-0.40.23.jar:?]
        at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:34) ~[io.airbyte-airbyte-commons-worker-0.40.23.jar:?]
        at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.23.jar:?]
        at java.lang.Thread.run(Thread.java:1589) ~[?:?]

@edgao There was an issue introduced before this PR that caused a failure when attempting to stop/close the process. This was due to calling .pid() on the KubePodProcess, which had not implemented the method. The issue with .pid() has been fixed in a subsequent commit #20028