`kafka/bin/kafka-topics.sh: No such file or directory` when running KStreamsYahooRunner about benchmarks HOT 3 OPEN

  /** Script that can be run on executors to install Kafka. */
  private def getInstallKafkaScript(dbfsDir: String, kafkaVersion: String) = {
    s"""#!/bin/bash
       |set -e
       |
       |sudo chown ubuntu /home/ubuntu
       |mkdir -p kafka && cd kafka
       |if [ ! -r "/dbfs/$dbfsDir/kafka-${kafkaVersion}.tgz" ]; then
       | wget -O /dbfs/$dbfsDir/kafka-${kafkaVersion}.tgz "http://mirrors.advancedhosters.com/apache/kafka/${kafkaVersion}/kafka_2.11-${kafkaVersion}.tgz"
       |fi
       |tar -xvzf /dbfs/$dbfsDir/kafka-${kafkaVersion}.tgz --strip 1 1> /dev/null 2>&1
     """.stripMargin
  }

  /** Script to install Flink on an executor. */
  private def getInstallFlinkScript(dbfsDir: String, flinkVersion: String, scalaVersion: String = "2.11") = {
    s"""#!/bin/bash
       |set -e
       |
       |sudo chown ubuntu /home/ubuntu
       |mkdir -p flink && cd flink
       |if [ ! -r "/dbfs/$dbfsDir/flink-${flinkVersion}.tgz" ]; then
       | wget -O /dbfs/$dbfsDir/flink-${flinkVersion}.tgz "http://mirrors.advancedhosters.com/apache/flink/flink-${flinkVersion}/flink-${flinkVersion}-bin-hadoop27-scala_${scalaVersion}.tgz"
       |fi
       |tar -xvzf /dbfs/$dbfsDir/flink-${flinkVersion}.tgz --strip 1 1> /dev/null 2>&1
     """.stripMargin
  }