Skip to content

Commit 2910586

Browse files
authored
fix: avro path fix for cluster mode (#980)
1 parent a3286c7 commit 2910586

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

java/bin/start.sh

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,8 @@ OPT_SPARK_VERSION="--version=1.2"
6868
OPT_PROJECT="--project=${GCP_PROJECT}"
6969
OPT_REGION="--region=${REGION}"
7070
OPT_JARS="--jars=file:///usr/lib/spark/connector/spark-avro.jar,${GCS_STAGING_LOCATION}/${JAR_FILE}"
71-
if [[ $OPT_SPARK_VERSION == *"=1.1"* ]]; then
72-
echo "Dataproc Serverless Runtime 1.1 Detected"
71+
if [[ $OPT_SPARK_VERSION == *"=1.1"* || $JOB_TYPE == "CLUSTER" ]]; then
72+
echo "Dataproc Serverless Runtime 1.1 or CLUSTER Job Type Detected"
7373
OPT_JARS="--jars=file:///usr/lib/spark/external/spark-avro.jar,${GCS_STAGING_LOCATION}/${JAR_FILE}"
7474
fi
7575
OPT_LABELS="--labels=job_type=dataproc_template"

java/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@
8686

8787
<!-- Spark Kafka Streaming Dependency. Aligned with Spark 3.5.1 -->
8888
<json4s.version>3.7.0-M11</json4s.version>
89-
<commons.io.version>2.13.0</commons.io.version>
89+
<commons.io.version>2.14.0</commons.io.version>
9090

9191
<!-- Spark Cassandra Connector -->
9292
<spark.cassandra.connector.version>3.5.1</spark.cassandra.connector.version>

0 commit comments

Comments
 (0)