sparksql 读取 kafka 报错？

SparkSession spark = SparkSession
.builder()
.appName("VideoStreamProcessor")
.master(prop.getProperty("spark.master.url"))
.getOrCreate();

    Dataset<Row> ds = spark.readStream().format("kafka")
    .option("kafka.bootstrap.servers","ip:9092")
    .option("subscribe", "topic")
      .load();
      ds.writeStream().outputMode("update").format("console").start();

报错，为什么？
Exception in thread "main" java.io.IOException: (null) entry in command string: null chmod 0644 C:\Users\root\AppData\Local\Temp\temporary-99b68965-f760-427b-80c8-0a0758362cda\metadata
at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:770)
at org.apache.hadoop.util.Shell.execCommand(Shell.java:866)
at org.apache.hadoop.util.Shell.execCommand(Shell.java:849)
。。。。。。。