From eed89d24e14454efd1a73ca41e3479d06fe834c8 Mon Sep 17 00:00:00 2001 From: shiyuhang <1136742008@qq.com> Date: Mon, 2 Sep 2024 16:50:47 +0800 Subject: [PATCH] fmt --- .../scala/com/pingcap/tispark/safepoint/ServiceSafePoint.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/com/pingcap/tispark/safepoint/ServiceSafePoint.scala b/core/src/main/scala/com/pingcap/tispark/safepoint/ServiceSafePoint.scala index 55438ed71..cc0983b1f 100644 --- a/core/src/main/scala/com/pingcap/tispark/safepoint/ServiceSafePoint.scala +++ b/core/src/main/scala/com/pingcap/tispark/safepoint/ServiceSafePoint.scala @@ -42,7 +42,8 @@ case class ServiceSafePoint( () => { val now = clientSession.getTiKVSession.getTimestamp if (now.getPhysical - TiTimestamp.extractPhysical(minStartTs) >= GCMaxWaitTime * 1000) { - val msg = s"Can not pause GC more than spark.tispark.gc_max_wait_time=$GCMaxWaitTime s. start_ts: ${minStartTs}, now: ${now.getVersion}. You can adjust spark.tispark.gc_max_wait_time to increase the gc max wait time." + val msg = + s"Can not pause GC more than spark.tispark.gc_max_wait_time=$GCMaxWaitTime s. start_ts: ${minStartTs}, now: ${now.getVersion}. You can adjust spark.tispark.gc_max_wait_time to increase the gc max wait time." logger.error(msg) sparkSession.stop() throw new TiInternalException(msg)