We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 697a9d8 commit a522924Copy full SHA for a522924
pramen/core/src/main/scala/za/co/absa/pramen/core/notify/pipeline/PipelineNotificationBuilderHtml.scala
@@ -234,8 +234,8 @@ class PipelineNotificationBuilderHtml(implicit conf: Config) extends PipelineNot
234
235
private[core] def getSparkApplicationIds: Seq[String] = {
236
sparkAppId match {
237
- case Some(appId) => (appId +: completedTasks.map(_.applicationId.trim).filter(_.nonEmpty)).distinct
238
- case None => completedTasks.map(_.applicationId.trim).filter(_.nonEmpty).distinct
+ case Some(appId) => (appId +: completedTasks.map(_.applicationId.trim).filter(_.nonEmpty)).distinct.toSeq
+ case None => completedTasks.map(_.applicationId.trim).filter(_.nonEmpty).distinct.toSeq
239
}
240
241
0 commit comments