Fix test.

RumbleDB · Jul 11, 2024 · a4499f0 · a4499f0
1 parent 1886b31
commit a4499f0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/org/rumbledb/runtime/flwor/FlworDataFrameUtils.java b/src/main/java/org/rumbledb/runtime/flwor/FlworDataFrameUtils.java
@@ -86,7 +86,7 @@
 import com.esotericsoftware.kryo.io.Input;
 import com.esotericsoftware.kryo.io.Output;
 
-import scala.collection.mutable.ArraySeq;
+import scala.collection.immutable.ArraySeq;
 import sparksoniq.spark.SparkSessionManager;
 
 public class FlworDataFrameUtils {
@@ -812,7 +812,7 @@ public static void deserializeWrappedParameters(
             Kryo kryo,
             Input input
     ) {
-        Object[] serializedParams = (Object[]) wrappedParameters.array();
+        Object[] serializedParams = (Object[]) wrappedParameters.unsafeArray();
         for (Object serializedParam : serializedParams) {
             if (serializedParam == null) {
                 deserializedParams.add(Collections.emptyList());

diff --git a/src/main/java/org/rumbledb/runtime/flwor/udfs/GroupClauseSerializeAggregateResultsUDF.java b/src/main/java/org/rumbledb/runtime/flwor/udfs/GroupClauseSerializeAggregateResultsUDF.java
@@ -23,7 +23,7 @@
 import org.apache.spark.sql.api.java.UDF1;
 import org.rumbledb.api.Item;
 import org.rumbledb.runtime.flwor.FlworDataFrameUtils;
-import scala.collection.mutable.ArraySeq;
+import scala.collection.immutable.ArraySeq;
 
 import java.util.ArrayList;
 import java.util.List;