File tree Expand file tree Collapse file tree 2 files changed +3
-11
lines changed
packaging/bundle-validation Expand file tree Collapse file tree 2 files changed +3
-11
lines changed Original file line number Diff line number Diff line change @@ -175,7 +175,7 @@ services:
175175 - " namenode"
176176
177177 zookeeper :
178- image : ' bitnami /zookeeper:3.4.12-r68'
178+ image : ' bitnamilegacy /zookeeper:3.4.12-r68'
179179 hostname : zookeeper
180180 container_name : zookeeper
181181 ports :
Original file line number Diff line number Diff line change @@ -81,19 +81,11 @@ test_spark_hadoop_mr_bundles () {
8181 local HIVE_PID=$!
8282 change_java_runtime_version
8383 echo " ::warning::validate.sh Writing sample data via Spark DataSource and run Hive Sync..."
84- $SPARK_HOME /bin/spark-shell --jars $JARS_DIR /spark.jar \
85- --conf ' spark.sql.extensions=org.apache.spark.sql.hudi.HoodieSparkSessionExtension' \
86- --conf ' spark.serializer=org.apache.spark.serializer.KryoSerializer' \
87- --conf ' spark.kryo.registrator=org.apache.spark.HoodieSparkKryoRegistrar' \
88- --conf ' spark.sql.catalog.spark_catalog=org.apache.spark.sql.hudi.catalog.HoodieCatalog' < $WORKDIR /spark_hadoop_mr/write.scala
84+ $SPARK_HOME /bin/spark-shell --jars $JARS_DIR /spark.jar < $WORKDIR /spark_hadoop_mr/write.scala
8985
9086 echo " ::warning::validate.sh Query and validate the results using Spark SQL"
9187 # save Spark SQL query results
92- $SPARK_HOME /bin/spark-shell --jars $JARS_DIR /spark.jar \
93- --conf ' spark.sql.extensions=org.apache.spark.sql.hudi.HoodieSparkSessionExtension' \
94- --conf ' spark.serializer=org.apache.spark.serializer.KryoSerializer' \
95- --conf ' spark.kryo.registrator=org.apache.spark.HoodieSparkKryoRegistrar' \
96- --conf ' spark.sql.catalog.spark_catalog=org.apache.spark.sql.hudi.catalog.HoodieCatalog' < $WORKDIR /spark_hadoop_mr/validate.scala
88+ $SPARK_HOME /bin/spark-shell --jars $JARS_DIR /spark.jar < $WORKDIR /spark_hadoop_mr/validate.scala
9789 numRecords=$( cat /tmp/spark-bundle/sparksql/trips/results/* .csv | wc -l)
9890 if [ " $numRecords " -ne 10 ]; then
9991 echo " ::error::validate.sh Spark SQL validation failed."
You can’t perform that action at this time.
0 commit comments