(airflow) branch main updated: Harden Java process exit (#68216)

[uranusjr]

This is an automated email from the ASF dual-hosted git repository.

uranusjr pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 9c5843e7a2d Harden Java process exit (#68216)
9c5843e7a2d is described below

commit 9c5843e7a2d69496b6527d1c839daec226952fd7
Author: Tzu-ping Chung <uranu...@gmail.com>
AuthorDate: Mon Jun 8 19:22:58 2026 +0800

    Harden Java process exit (#68216)
---
 .../sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Comm.kt  | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git 
a/java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Comm.kt 
b/java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Comm.kt
index 86bf3ef7e04..5d917af3291 100644
--- a/java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Comm.kt
+++ b/java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Comm.kt
@@ -29,7 +29,6 @@ import org.apache.airflow.sdk.execution.comm.ErrorResponse
 import org.apache.airflow.sdk.execution.comm.StartupDetails
 import kotlin.concurrent.atomics.AtomicInt
 import kotlin.concurrent.atomics.ExperimentalAtomicApi
-import kotlin.system.exitProcess
 
 data class IncomingFrame(
   val id: Int,
@@ -101,12 +100,9 @@ class CoordinatorComm(
   suspend fun handleIncoming(frame: IncomingFrame) {
     when (val request = frame.body) {
       null -> {}
-      is ErrorResponse -> {
-        println("Error!! id=${frame.id} [${request.error}] ${request.detail}") 
// TODO: Handle error.
-        exitProcess(1)
-      }
+      is ErrorResponse -> throw ApiError("[${request.error}] 
${request.detail}")
       is StartupDetails -> {
-        sendMessage(frame.id, runTask(bundle, request, this))
+        communicate<Unit>(runTask(bundle, request, this))
         shutDownRequested = true
       }
     }