@@ -73,16 +73,26 @@ pushd ${spark_dir}
7373
7474 # Run pyarrow related Python tests only
7575 spark_python_tests=(
76- " pyspark.sql.tests.test_arrow"
77- " pyspark.sql.tests.test_pandas_map"
78- " pyspark.sql.tests.test_pandas_cogrouped_map"
79- " pyspark.sql.tests.test_pandas_udf"
80- " pyspark.sql.tests.test_pandas_udf_scalar"
81- " pyspark.sql.tests.test_pandas_udf_grouped_agg"
82- " pyspark.sql.tests.test_pandas_udf_window" )
76+ " pyspark.sql.tests.test_arrow" )
8377
8478 if [ " ${SPARK_VERSION} " != " master" ]; then
85- spark_python_tests+=(" pyspark.sql.tests.test_pandas_grouped_map" )
79+ spark_python_tests+=(
80+ " pyspark.sql.tests.test_pandas_grouped_map"
81+ " pyspark.sql.tests.test_pandas_map"
82+ " pyspark.sql.tests.test_pandas_cogrouped_map"
83+ " pyspark.sql.tests.test_pandas_udf"
84+ " pyspark.sql.tests.test_pandas_udf_scalar"
85+ " pyspark.sql.tests.test_pandas_udf_grouped_agg"
86+ " pyspark.sql.tests.test_pandas_udf_window" )
87+ else
88+ spark_python_tests+=(
89+ " pyspark.sql.tests.pandas.test_pandas_grouped_map"
90+ " pyspark.sql.tests.pandas.test_pandas_map"
91+ " pyspark.sql.tests.pandas.test_pandas_cogrouped_map"
92+ " pyspark.sql.tests.pandas.test_pandas_udf"
93+ " pyspark.sql.tests.pandas.test_pandas_udf_scalar"
94+ " pyspark.sql.tests.pandas.test_pandas_udf_grouped_agg"
95+ " pyspark.sql.tests.pandas.test_pandas_udf_window" )
8696 fi
8797
8898 (echo " Testing PySpark:" ; IFS=$' \n ' ; echo " ${spark_python_tests[*]} " )
0 commit comments