@@ -340,9 +340,9 @@ class KubernetesAppReport(driver: Option[Pod], executors: Seq[Pod],
340
340
val timeRange = livyConf.get(LivyConf .KUBERNETES_GRAFANA_TIME_RANGE )
341
341
val lokiDatasource = livyConf.get(LivyConf .KUBERNETES_GRAFANA_LOKI_DATASOURCE )
342
342
return Some (
343
- s """ $grafanaUrl/explore?left=["now- $timeRange","now"," $lokiDatasource",
344
- | {"expr":"{job%3D\" $namespace%2F $driverPodName\"}"},
345
- | {"ui":[true,true,true,"none"]}] """ .stripMargin
343
+ s """ $grafanaUrl/explore?left=["now- $timeRange","now"," $lokiDatasource", """ +
344
+ s """ {"expr":"{job%3D\" $namespace%2F $driverPodName\"}"}, """ +
345
+ s """ {"ui":[true,true,true,"none"]}] """
346
346
)
347
347
}
348
348
}
@@ -361,11 +361,11 @@ class KubernetesAppReport(driver: Option[Pod], executors: Seq[Pod],
361
361
val labels = e.getMetadata.getLabels
362
362
val sparkAppTag = labels.get(SPARK_APP_TAG_LABEL )
363
363
val sparkExecId = labels.get(SPARK_EXEC_ID_LABEL )
364
- s """ executor- $sparkExecId#
365
- | $grafanaUrl/explore?left=["now- $timeRange","now"," $lokiDatasource",
366
- | {"expr":"{ $sparkAppTagLogLabel%3D\" $sparkAppTag\",
367
- | $sparkExecIdLogLabel%3D\" $sparkExecId\"}"},
368
- | {"ui":[true,true,true,"none"]}] """ .stripMargin
364
+ s " executor- $sparkExecId# " +
365
+ s """ $grafanaUrl/explore?left=["now- $timeRange","now"," $lokiDatasource", """ +
366
+ s """ {"expr":"{ $sparkAppTagLogLabel%3D\" $sparkAppTag\", """ +
367
+ s """ $sparkExecIdLogLabel%3D\" $sparkExecId\"}"}, """ +
368
+ s """ {"ui":[true,true,true,"none"]}] """
369
369
})
370
370
if (urls.nonEmpty) return Some (urls.mkString(" ;" ))
371
371
}
0 commit comments