diff --git a/phoenix5-spark3/src/main/scala/org/apache/phoenix/spark/sql/connector/PhoenixSparkSqlRelation.scala b/phoenix5-spark3/src/main/scala/org/apache/phoenix/spark/sql/connector/PhoenixSparkSqlRelation.scala
index 2b8e074..93c7c0d 100644
--- a/phoenix5-spark3/src/main/scala/org/apache/phoenix/spark/sql/connector/PhoenixSparkSqlRelation.scala
+++ b/phoenix5-spark3/src/main/scala/org/apache/phoenix/spark/sql/connector/PhoenixSparkSqlRelation.scala
@@ -25,7 +25,7 @@ case class PhoenixSparkSqlRelation(
     val batch = scanBuilder.build().toBatch
     val rdd = new DataSourceRDD(
       sqlContext.sparkContext,
-      batch.planInputPartitions(),
+      Seq(batch.planInputPartitions().toSeq),
       batch.createReaderFactory(),
       false,
       Map.empty
diff --git a/pom.xml b/pom.xml
index 852a6de..b33fb0b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -126,7 +126,7 @@
     <spark.version>2.4.8</spark.version>
     <scala.version.for.spark2>2.11.12</scala.version.for.spark2>
     <scala.binary.version.for.spark2>2.11</scala.binary.version.for.spark2>
-    <spark3.version>3.2.4</spark3.version>
+    <spark3.version>3.4.4</spark3.version>
     <scala.version.for.spark3>2.12.18</scala.version.for.spark3>
     <scala.binary.version.for.spark3>2.12</scala.binary.version.for.spark3>
     <log4j.version>1.2.17</log4j.version>