我如何使用Java I＆＃x27; ve使用df.write（）。parquet但会有以下错误？

Question

package com.evampsaanga.imran.testing;

import org.apache.spark.SparkConf;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

public class ReadingCsv {
    public static void main(String[] args) {

    
    SparkConf conf = new SparkConf().setAppName("Text File Data Load").setMaster("local").set("spark.driver.host","localhost").set("spark.testing.memory", "2147480000");       
    SparkSession spark = SparkSession.builder().config(conf).getOrCreate(); 
    Dataset<Row> df = spark.read()
                .format("org.apache.spark.sql.execution.datasources.csv.CSVFileFormat")
                .option("sep", ",")
                .option("inferSchema", true)
                .option("header", true)
                .load("E:/CarsData.csv");
    df.write().parquet("test.parquet");

我已经使用了df.write.parquet，但是我遇到了这个错误

Exception in thread "main" org.apache.spark.sql.AnalysisException: Multiple sources found for parquet (org.apache.spark.sql.execution.datasources.v2.parquet.ParquetDataSourceV2, org.apache.spark.sql 。 atrg.apache.spark.sql.execution.datasources.datasource $ .lookupdatasource（datasource.scala：702） atrg.apache.spark.sql.execution.datasources.datasource $ .lookupdatasourcev2（datasource.scala：728） atrg.apache.spark.sql.dataframewriter.lookupv2provider（dataframewriter.scala：948） 请访问org.apache.spark.sql.dataframewriter.save（dataframewriter.scala：285） atrg.apache.spark.sql.dataframewriter.save（dataFrameWriter.scala：269） atrg.apache.spark.sql.dataframewriter.parquet（dataframewriter.scala：829） 在com.evampsaanga.imran.testing.readingcsv.main（Readscsv.java:23）