This is an automated email from the ASF dual-hosted git repository.
stoty pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix-connectors.git
The following commit(s) were added to refs/heads/master by this push:
new 446198b PHOENIX-7465 Update to spark 3.4.4 (#148)
446198b is described below
commit 446198b497acdd11fbafd8bc4532cc63f75f8ca6
Author: szucsvillo <[email protected]>
AuthorDate: Mon Nov 25 09:29:43 2024 +0100
PHOENIX-7465 Update to spark 3.4.4 (#148)
---
.../apache/phoenix/spark/sql/connector/PhoenixSparkSqlRelation.scala | 2 +-
pom.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
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>
