diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala index 9f61021b013..3516c3771aa 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala @@ -99,10 +99,11 @@ class KyuubiSyncThriftClient private ( remoteEngineBroken = false } catch { case e: Throwable => - warn(s"The engine[$engineId] alive probe fails", e) + val engineIdStr = engineId.getOrElse("") + warn(s"The engine[$engineIdStr] alive probe fails", e) val now = System.currentTimeMillis() if (now - engineLastAlive > engineAliveTimeout) { - error(s"Mark the engine[$engineId] not alive with no recent alive probe" + + error(s"Mark the engine[$engineIdStr] not alive with no recent alive probe" + s" success: ${now - engineLastAlive} ms exceeds timeout $engineAliveTimeout ms") remoteEngineBroken = true }