[SPARK-56111][CORE] Add SparkContext.isDriver() and use it across the codebase

cloud-fan · terana · commit 8d500b8fa1e9 · 2026-03-23T13:00:56.000Z
### What changes were proposed in this pull request? Add a `SparkContext.isDriver(executorId)` utility method and replace all manual `executorId == SparkContext.DRIVER_IDENTIFIER` / `executorId != SparkContext.DRIVER_IDENTIFIER` checks across the codebase with it. ### Why are the changes needed? The driver-detection pattern `executorId == SparkContext.DRIVER_IDENTIFIER` is duplicated in ~20 places across core, SQL, streaming, profiler, and Kubernetes modules. Centralizing it in a single method improves readability and reduces duplication. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Existing tests — this is a pure refactoring with no behavior change. ### Was this patch authored or co-authored using generative AI tooling? Generated-by: Claude Opus 4.6 Closes apache#54922 from cloud-fan/SPARK-53915-followup. Authored-by: Wenchen Fan <wenchen@databricks.com> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
diff --git a/connector/profiler/src/main/scala/org/apache/spark/profiler/SparkAsyncProfiler.scala b/connector/profiler/src/main/scala/org/apache/spark/profiler/SparkAsyncProfiler.scala
@@ -23,8 +23,7 @@ import one.profiler.{AsyncProfiler, AsyncProfilerLoader}
 import org.apache.hadoop.fs.{FileSystem, FSDataOutputStream, Path}
 import org.apache.hadoop.fs.permission.FsPermission
 
-import org.apache.spark.SparkConf
-import org.apache.spark.SparkContext.DRIVER_IDENTIFIER
+import org.apache.spark.{SparkConf, SparkContext}
 import org.apache.spark.deploy.SparkHadoopUtil
 import org.apache.spark.internal.Logging
 import org.apache.spark.internal.LogKeys.PATH
@@ -45,7 +44,7 @@ private[spark] class SparkAsyncProfiler(conf: SparkConf, executorId: String) ext
   private def getAppId: Option[String] = conf.getOption("spark.app.id")
   private def getAttemptId: Option[String] = conf.getOption("spark.app.attempt.id")
 
-  private val profileFile = if (executorId == DRIVER_IDENTIFIER) {
+  private val profileFile = if (SparkContext.isDriver(executorId)) {
     s"profile-$executorId.jfr"
   } else {
     s"profile-exec-$executorId.jfr"
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -754,7 +754,7 @@ class SparkContext(config: SparkConf) extends Logging {
    */
   private[spark] def getExecutorThreadDump(executorId: String): Option[Array[ThreadStackTrace]] = {
     try {
-      if (executorId == SparkContext.DRIVER_IDENTIFIER) {
+      if (SparkContext.isDriver(executorId)) {
         Some(Utils.getThreadDump())
       } else {
         env.blockManager.master.getExecutorEndpointRef(executorId) match {
@@ -786,7 +786,7 @@ class SparkContext(config: SparkConf) extends Logging {
    */
   private[spark] def getExecutorHeapHistogram(executorId: String): Option[Array[String]] = {
     try {
-      if (executorId == SparkContext.DRIVER_IDENTIFIER) {
+      if (SparkContext.isDriver(executorId)) {
         Some(Utils.getHeapHistogram())
       } else {
         env.blockManager.master.getExecutorEndpointRef(executorId) match {
@@ -3163,6 +3163,11 @@ object SparkContext extends Logging {
   /** Separator of tags in SPARK_JOB_TAGS property */
   private[spark] val SPARK_JOB_TAGS_SEP = ","
 
+  /** Returns true if the given executor ID identifies the driver. */
+  private[spark] def isDriver(executorId: String): Boolean = {
+    DRIVER_IDENTIFIER == executorId
+  }
+
   // Same rules apply to Spark Connect execution tags, see ExecuteHolder.throwIfInvalidTag
   private[spark] def throwIfInvalidTag(tag: String) = {
     if (tag == null) {
diff --git a/core/src/main/scala/org/apache/spark/SparkEnv.scala b/core/src/main/scala/org/apache/spark/SparkEnv.scala
@@ -248,7 +248,7 @@ class SparkEnv (
     Preconditions.checkState(null == _shuffleManager,
       "Shuffle manager already initialized to %s", _shuffleManager)
     try {
-      _shuffleManager = ShuffleManager.create(conf, executorId == SparkContext.DRIVER_IDENTIFIER)
+      _shuffleManager = ShuffleManager.create(conf, SparkContext.isDriver(executorId))
     } finally {
       // Signal that the ShuffleManager has been initialized
       shuffleManagerInitLatch.countDown()
@@ -356,7 +356,7 @@ object SparkEnv extends Logging {
       listenerBus: LiveListenerBus = null,
       mockOutputCommitCoordinator: Option[OutputCommitCoordinator] = None): SparkEnv = {
 
-    val isDriver = executorId == SparkContext.DRIVER_IDENTIFIER
+    val isDriver = SparkContext.isDriver(executorId)
 
     // Listener bus is only used on the driver
     if (isDriver) {
diff --git a/core/src/main/scala/org/apache/spark/rpc/netty/MessageLoop.scala b/core/src/main/scala/org/apache/spark/rpc/netty/MessageLoop.scala
@@ -116,7 +116,7 @@ private class SharedMessageLoop(
       .getOrElse(math.max(2, availableCores))
 
     conf.get(EXECUTOR_ID).map { id =>
-      val role = if (id == SparkContext.DRIVER_IDENTIFIER) "driver" else "executor"
+      val role = if (SparkContext.isDriver(id)) "driver" else "executor"
       conf.getInt(s"spark.$role.rpc.netty.dispatcher.numThreads", modNumThreads)
     }.getOrElse(modNumThreads)
   }
diff --git a/core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala b/core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
@@ -50,7 +50,7 @@ private[netty] class NettyRpcEnv(
     securityManager: SecurityManager,
     numUsableCores: Int) extends RpcEnv(conf) with Logging {
   val role = conf.get(EXECUTOR_ID).map { id =>
-    if (id == SparkContext.DRIVER_IDENTIFIER) "driver" else "executor"
+    if (SparkContext.isDriver(id)) "driver" else "executor"
   }
 
   private[netty] val transportConf = SparkTransportConf.fromSparkConf(
diff --git a/core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala b/core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala
@@ -249,7 +249,7 @@ private[spark] class EventLoggingListener(
 
   override def onExecutorMetricsUpdate(event: SparkListenerExecutorMetricsUpdate): Unit = {
     if (shouldLogStageExecutorMetrics) {
-      if (event.execId == SparkContext.DRIVER_IDENTIFIER) {
+      if (SparkContext.isDriver(event.execId)) {
         logEvent(event)
       }
       event.executorUpdates.foreach { case (stageKey1, newPeaks) =>
diff --git a/core/src/main/scala/org/apache/spark/shuffle/ShuffleBlockPusher.scala b/core/src/main/scala/org/apache/spark/shuffle/ShuffleBlockPusher.scala
@@ -502,7 +502,7 @@ private[spark] object ShuffleBlockPusher {
   private val BLOCK_PUSHER_POOL: ExecutorService = {
     val conf = SparkEnv.get.conf
     if (Utils.isPushBasedShuffleEnabled(conf,
-        isDriver = SparkContext.DRIVER_IDENTIFIER == SparkEnv.get.executorId)) {
+        isDriver = SparkContext.isDriver(SparkEnv.get.executorId))) {
       val numThreads = conf.get(SHUFFLE_NUM_PUSH_THREADS)
         .getOrElse(conf.getInt(SparkLauncher.EXECUTOR_CORES, 1))
       ThreadUtils.newDaemonFixedThreadPool(numThreads, "shuffle-block-push-thread")
diff --git a/core/src/main/scala/org/apache/spark/status/AppStatusListener.scala b/core/src/main/scala/org/apache/spark/status/AppStatusListener.scala
@@ -362,11 +362,11 @@ private[spark] class AppStatusListener(
     // Implicitly exclude every available executor for the stage associated with this node
     Option(liveStages.get((stageId, stageAttemptId))).foreach { stage =>
       val executorIds = liveExecutors.values.filter(exec => exec.host == hostId
-        && exec.executorId != SparkContext.DRIVER_IDENTIFIER).map(_.executorId).toSeq
+        && !SparkContext.isDriver(exec.executorId)).map(_.executorId).toSeq
       setStageExcludedStatus(stage, now, executorIds: _*)
     }
     liveExecutors.values.filter(exec => exec.hostname == hostId
-      && exec.executorId != SparkContext.DRIVER_IDENTIFIER).foreach { exec =>
+      && !SparkContext.isDriver(exec.executorId)).foreach { exec =>
       addExcludedStageTo(exec, stageId, now)
     }
   }
@@ -413,7 +413,7 @@ private[spark] class AppStatusListener(
 
     // Implicitly (un)exclude every executor associated with the node.
     liveExecutors.values.foreach { exec =>
-      if (exec.hostname == host && exec.executorId != SparkContext.DRIVER_IDENTIFIER) {
+      if (exec.hostname == host && !SparkContext.isDriver(exec.executorId)) {
         updateExecExclusionStatus(exec, excluded, now)
       }
     }
diff --git a/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala b/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
@@ -103,7 +103,7 @@ private[spark] class AppStatusStore(
   }
 
   private def replaceExec(origin: v1.ExecutorSummary): v1.ExecutorSummary = {
-    if (origin.id == SparkContext.DRIVER_IDENTIFIER) {
+    if (SparkContext.isDriver(origin.id)) {
       replaceDriverGcTime(origin, extractGcTime(origin), extractAppTime)
     } else {
       origin
diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala
@@ -182,7 +182,7 @@ private[v1] class AbstractApplicationResource extends BaseAppResource {
   }
 
   private def checkExecutorId(execId: String): Unit = {
-    if (execId != SparkContext.DRIVER_IDENTIFIER && !execId.forall(Character.isDigit)) {
+    if (!SparkContext.isDriver(execId) && !execId.forall(Character.isDigit)) {
       throw new BadParameterException(
         s"Invalid executorId: neither '${SparkContext.DRIVER_IDENTIFIER}' nor number.")
     }
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -213,7 +213,7 @@ private[spark] class BlockManager(
 
   // same as `conf.get(config.SHUFFLE_SERVICE_ENABLED)`
   private[spark] val externalShuffleServiceEnabled: Boolean = externalBlockStoreClient.isDefined
-  private val isDriver = executorId == SparkContext.DRIVER_IDENTIFIER
+  private val isDriver = SparkContext.isDriver(executorId)
 
   private val remoteReadNioBufferConversion =
     conf.get(Network.NETWORK_REMOTE_READ_NIO_BUFFER_CONVERSION)
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManagerId.scala b/core/src/main/scala/org/apache/spark/storage/BlockManagerId.scala
@@ -65,7 +65,7 @@ class BlockManagerId private (
   def topologyInfo: Option[String] = topologyInfo_
 
   def isDriver: Boolean = {
-    executorId == SparkContext.DRIVER_IDENTIFIER
+    SparkContext.isDriver(executorId)
   }
 
   override def writeExternal(out: ObjectOutput): Unit = Utils.tryOrIOException {
diff --git a/core/src/test/scala/org/apache/spark/HeartbeatReceiverSuite.scala b/core/src/test/scala/org/apache/spark/HeartbeatReceiverSuite.scala
@@ -305,7 +305,7 @@ class HeartbeatReceiverSuite
     // We may receive undesired SparkListenerExecutorAdded from LocalSchedulerBackend,
     // so exclude it from the map. See SPARK-10800.
     heartbeatReceiver.invokePrivate(_executorLastSeen()).
-      filter { case (k, _) => k != SparkContext.DRIVER_IDENTIFIER }
+      filter { case (k, _) => !SparkContext.isDriver(k) }
   }
 }
 
diff --git a/core/src/test/scala/org/apache/spark/SparkContextSuite.scala b/core/src/test/scala/org/apache/spark/SparkContextSuite.scala
@@ -849,7 +849,7 @@ class SparkContextSuite extends SparkFunSuite with LocalSparkContext with Eventu
     val listener = new SparkListener {
       override def onExecutorMetricsUpdate(
           executorMetricsUpdate: SparkListenerExecutorMetricsUpdate): Unit = {
-        if (executorMetricsUpdate.execId != SparkContext.DRIVER_IDENTIFIER) {
+        if (!SparkContext.isDriver(executorMetricsUpdate.execId)) {
           runningTaskIds = executorMetricsUpdate.accumUpdates.map(_._1)
         }
       }
diff --git a/core/src/test/scala/org/apache/spark/scheduler/EventLoggingListenerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/EventLoggingListenerSuite.scala
@@ -531,7 +531,7 @@ class EventLoggingListenerSuite extends SparkFunSuite with LocalSparkContext wit
       events.foreach { event =>
         event match {
           case metricsUpdate: SparkListenerExecutorMetricsUpdate
-            if metricsUpdate.execId != SparkContext.DRIVER_IDENTIFIER =>
+            if !SparkContext.isDriver(metricsUpdate.execId) =>
           case stageCompleted: SparkListenerStageCompleted =>
             val execIds = Set[String]()
             (1 to 3).foreach { _ =>
@@ -631,7 +631,7 @@ class EventLoggingListenerSuite extends SparkFunSuite with LocalSparkContext wit
       case (expected: SparkListenerExecutorMetricsUpdate,
           actual: SparkListenerExecutorMetricsUpdate) =>
         assert(expected.execId == actual.execId)
-        assert(expected.execId == SparkContext.DRIVER_IDENTIFIER)
+        assert(SparkContext.isDriver(expected.execId))
       case (expected: SparkListenerEvent, actual: SparkListenerEvent) =>
         assert(expected === actual)
     }
diff --git a/core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionIntegrationSuite.scala b/core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionIntegrationSuite.scala
@@ -207,7 +207,7 @@ class BlockManagerDecommissionIntegrationSuite extends SparkFunSuite with LocalS
       override def onExecutorMetricsUpdate(
           executorMetricsUpdate: SparkListenerExecutorMetricsUpdate): Unit = {
         val executorId = executorMetricsUpdate.execId
-        if (executorId != SparkContext.DRIVER_IDENTIFIER) {
+        if (!SparkContext.isDriver(executorId)) {
           val validUpdate = executorMetricsUpdate
             .accumUpdates
             .flatMap(_._4)
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/ExecutorRollPlugin.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/ExecutorRollPlugin.scala
@@ -111,7 +111,7 @@ class ExecutorRollDriverPlugin extends DriverPlugin with Logging {
   private def choose(list: Seq[v1.ExecutorSummary], policy: ExecutorRollPolicy.Value)
       : Option[String] = {
     val listWithoutDriver = list
-      .filterNot(_.id.equals(SparkContext.DRIVER_IDENTIFIER))
+      .filterNot(e => SparkContext.isDriver(e.id))
       .filter(_.totalTasks >= minTasks)
     val sortedList = policy match {
       case ExecutorRollPolicy.ID =>
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala
@@ -988,7 +988,7 @@ object StateStoreProvider extends Logging {
   private[state] def coordinatorRef: Option[StateStoreCoordinatorRef] = synchronized {
     val env = SparkEnv.get
     if (env != null) {
-      val isDriver = env.executorId == SparkContext.DRIVER_IDENTIFIER
+      val isDriver = SparkContext.isDriver(env.executorId)
       // If running locally, then the coordinator reference in stateStoreCoordinatorRef may have
       // become inactive as SparkContext + SparkEnv may have been restarted. Hence, when running in
       // driver, always recreate the reference.
@@ -1765,8 +1765,7 @@ object StateStore extends Logging {
   private def coordinatorRef: Option[StateStoreCoordinatorRef] = loadedProviders.synchronized {
     val env = SparkEnv.get
     if (env != null) {
-      val isDriver =
-        env.executorId == SparkContext.DRIVER_IDENTIFIER
+      val isDriver = SparkContext.isDriver(env.executorId)
       // If running locally, then the coordinator reference in _coordRef may be have become inactive
       // as SparkContext + SparkEnv may have been restarted. Hence, when running in driver,
       // always recreate the reference.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/util/GlobalSingletonManualClock.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/util/GlobalSingletonManualClock.scala
@@ -17,8 +17,7 @@
 
 package org.apache.spark.sql.streaming.util
 
-import org.apache.spark.SparkContext.DRIVER_IDENTIFIER
-import org.apache.spark.SparkEnv
+import org.apache.spark.{SparkContext, SparkEnv}
 import org.apache.spark.internal.Logging
 import org.apache.spark.rpc.{RpcCallContext, RpcEnv, ThreadSafeRpcEndpoint}
 import org.apache.spark.util.RpcUtils
@@ -73,8 +72,7 @@ class GlobalManualClock(endpointName: String)
 
   private def isDriver: Boolean = {
     val executorId = SparkEnv.get.executorId
-    // Check for null to match the behavior of executorId == DRIVER_IDENTIFIER
-    executorId != null && executorId.startsWith(DRIVER_IDENTIFIER)
+    SparkContext.isDriver(executorId)
   }
 
   override def getTimeMillis(): Long = {
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala
@@ -414,7 +414,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
       Seq(ExecutorCacheTaskLocation(blockManagerId.host, blockManagerId.executorId))
     } else {
       ssc.sparkContext.env.blockManager.master.getMemoryStatus.filter { case (blockManagerId, _) =>
-        blockManagerId.executorId != SparkContext.DRIVER_IDENTIFIER // Ignore the driver location
+        !SparkContext.isDriver(blockManagerId.executorId) // Ignore the driver location
       }.map { case (blockManagerId, _) =>
         ExecutorCacheTaskLocation(blockManagerId.host, blockManagerId.executorId)
       }.toSeq

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,7 @@ private class SharedMessageLoop(`
`116`	`116`	`.getOrElse(math.max(2, availableCores))`
`117`	`117`
`118`	`118`	`conf.get(EXECUTOR_ID).map { id =>`
`119`		`- val role = if (id == SparkContext.DRIVER_IDENTIFIER) "driver" else "executor"`
	`119`	`+ val role = if (SparkContext.isDriver(id)) "driver" else "executor"`
`120`	`120`	`conf.getInt(s"spark.$role.rpc.netty.dispatcher.numThreads", modNumThreads)`
`121`	`121`	`}.getOrElse(modNumThreads)`
`122`	`122`	`}`
Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ private[netty] class NettyRpcEnv(`
`50`	`50`	`securityManager: SecurityManager,`
`51`	`51`	`numUsableCores: Int) extends RpcEnv(conf) with Logging {`
`52`	`52`	`val role = conf.get(EXECUTOR_ID).map { id =>`
`53`		`- if (id == SparkContext.DRIVER_IDENTIFIER) "driver" else "executor"`
	`53`	`+ if (SparkContext.isDriver(id)) "driver" else "executor"`
`54`	`54`	`}`
`55`	`55`
`56`	`56`	`private[netty] val transportConf = SparkTransportConf.fromSparkConf(`
Original file line number	Diff line number	Diff line change
`@@ -249,7 +249,7 @@ private[spark] class EventLoggingListener(`
`249`	`249`
`250`	`250`	`override def onExecutorMetricsUpdate(event: SparkListenerExecutorMetricsUpdate): Unit = {`
`251`	`251`	`if (shouldLogStageExecutorMetrics) {`
`252`		`- if (event.execId == SparkContext.DRIVER_IDENTIFIER) {`
	`252`	`+ if (SparkContext.isDriver(event.execId)) {`
`253`	`253`	`logEvent(event)`
`254`	`254`	`}`
`255`	`255`	`event.executorUpdates.foreach { case (stageKey1, newPeaks) =>`
Original file line number	Diff line number	Diff line change
`@@ -362,11 +362,11 @@ private[spark] class AppStatusListener(`
`362`	`362`	`// Implicitly exclude every available executor for the stage associated with this node`
`363`	`363`	`Option(liveStages.get((stageId, stageAttemptId))).foreach { stage =>`
`364`	`364`	`val executorIds = liveExecutors.values.filter(exec => exec.host == hostId`
`365`		`- && exec.executorId != SparkContext.DRIVER_IDENTIFIER).map(_.executorId).toSeq`
	`365`	`+ && !SparkContext.isDriver(exec.executorId)).map(_.executorId).toSeq`
`366`	`366`	`setStageExcludedStatus(stage, now, executorIds: _*)`
`367`	`367`	`}`
`368`	`368`	`liveExecutors.values.filter(exec => exec.hostname == hostId`
`369`		`- && exec.executorId != SparkContext.DRIVER_IDENTIFIER).foreach { exec =>`
	`369`	`+ && !SparkContext.isDriver(exec.executorId)).foreach { exec =>`
`370`	`370`	`addExcludedStageTo(exec, stageId, now)`
`371`	`371`	`}`
`372`	`372`	`}`
`@@ -413,7 +413,7 @@ private[spark] class AppStatusListener(`
`413`	`413`
`414`	`414`	`// Implicitly (un)exclude every executor associated with the node.`
`415`	`415`	`liveExecutors.values.foreach { exec =>`
`416`		`- if (exec.hostname == host && exec.executorId != SparkContext.DRIVER_IDENTIFIER) {`
	`416`	`+ if (exec.hostname == host && !SparkContext.isDriver(exec.executorId)) {`
`417`	`417`	`updateExecExclusionStatus(exec, excluded, now)`
`418`	`418`	`}`
`419`	`419`	`}`
Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ private[spark] class AppStatusStore(`
`103`	`103`	`}`
`104`	`104`
`105`	`105`	`private def replaceExec(origin: v1.ExecutorSummary): v1.ExecutorSummary = {`
`106`		`- if (origin.id == SparkContext.DRIVER_IDENTIFIER) {`
	`106`	`+ if (SparkContext.isDriver(origin.id)) {`
`107`	`107`	`replaceDriverGcTime(origin, extractGcTime(origin), extractAppTime)`
`108`	`108`	`} else {`
`109`	`109`	`origin`
Original file line number	Diff line number	Diff line change
`@@ -182,7 +182,7 @@ private[v1] class AbstractApplicationResource extends BaseAppResource {`
`182`	`182`	`}`
`183`	`183`
`184`	`184`	`private def checkExecutorId(execId: String): Unit = {`
`185`		`- if (execId != SparkContext.DRIVER_IDENTIFIER && !execId.forall(Character.isDigit)) {`
	`185`	`+ if (!SparkContext.isDriver(execId) && !execId.forall(Character.isDigit)) {`
`186`	`186`	`throw new BadParameterException(`
`187`	`187`	`s"Invalid executorId: neither '${SparkContext.DRIVER_IDENTIFIER}' nor number.")`
`188`	`188`	`}`