We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fde1213 commit 8102d6eCopy full SHA for 8102d6e
python/run-tests
@@ -102,7 +102,7 @@ function run_streaming_tests() {
102
103
KAFKA_ASSEMBLY_DIR="$FWDIR"/external/kafka-assembly
104
JAR_PATH="${KAFKA_ASSEMBLY_DIR}/target/scala-${SPARK_SCALA_VERSION}"
105
- for f in "${JAR_PATH}"/spark-streaming-kafka-assembly-*.jar; do
+ for f in "${JAR_PATH}"/spark-streaming-kafka-assembly*.jar; do
106
if [[ ! -e "$f" ]]; then
107
echo "Failed to find Spark Streaming Kafka assembly jar in $KAFKA_ASSEMBLY_DIR" 1>&2
108
echo "You need to build Spark before running this program" 1>&2
0 commit comments