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)