You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@livy.apache.org by gg...@apache.org on 2026/09/15 14:01:32 UTC

(livy) branch master updated: [LIVY-1072][FOLLOWUP] Fix Scala 2.13 compile error in SparkKubernetesApp

This is an automated email from the ASF dual-hosted git repository.

gyogal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/livy.git


The following commit(s) were added to refs/heads/master by this push:
     new e52d1d16 [LIVY-1072][FOLLOWUP] Fix Scala 2.13 compile error in SparkKubernetesApp
e52d1d16 is described below

commit e52d1d1639f7cb39372fc59f97fee524a0049fff
Author: Gyorgy Gal <27...@users.noreply.github.com>
AuthorDate: Tue Sep 15 14:01:27 2026 +0000

    [LIVY-1072][FOLLOWUP] Fix Scala 2.13 compile error in SparkKubernetesApp
    
    ## What changes were proposed in this pull request?
    
    `KubernetesExtensions.getApplicationReport` failed to compile under
    Scala 2.13 (the default build): `client.pods...list.getItems.asScala`
    returns `scala.collection.mutable.Buffer`, but the enclosing `val
    executors: Seq[Pod]` requires `scala.collection.immutable.Seq` (the 2.13
    default for the unqualified `Seq` alias). Scala 2.12 allowed the
    implicit widening; 2.13 does not.
    
    Adds `.toSeq`, matching the same conversion already used a few lines
    above for the driver-pod lookup.
    
    ## How was this patch tested?
    
    `mvn install -pl core/scala-2.13,server -am -DskipTests` failed with
    this exact type-mismatch error before the fix and succeeds after it.
    
    ## Was this patch authored or co-authored using generative AI tooling?
    
    Generated-by: Claude Code (Sonnet 5)
---
 server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala b/server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala
index bb8eb291..fec93ca4 100644
--- a/server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala
+++ b/server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala
@@ -742,7 +742,7 @@ private[utils] object KubernetesExtensions {
               appTagLabel -> app.getApplicationTag,
               SPARK_ROLE_LABEL -> SPARK_ROLE_EXECUTOR
             ).asJava)
-            .list.getItems.asScala
+            .list.getItems.asScala.toSeq
         } else {
           Seq.empty
         }