fix

ytsaurus · Jun 20, 2024 · 6351e54 · 6351e54
1 parent cee5717
commit 6351e54
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/main/scala/org/apache/spark/scheduler/cluster/ytsaurus/YTsaurusOperationManager.scala b/...src/main/scala/org/apache/spark/scheduler/cluster/ytsaurus/YTsaurusOperationManager.scala
@@ -325,7 +325,7 @@ private[spark] object YTsaurusOperationManager extends Logging {
       val unpackArchivesCommands = applicationFiles(conf).map { file =>
         filePaths.add(file.toNode())
         file.unpackCommand
-      }.filter(cmd => cmd.isDefined)
+      }.filter(cmd => cmd.isDefined).map(cmd => cmd.get)
 
       val unpackArchivesCommand = if (unpackArchivesCommands.nonEmpty) {
         unpackArchivesCommands.mkString(" && ") + " &&"