由于您正在使用适用于Spark3.1的连接器与Spark3.2.1配合使用，因此不支持查询下推

如果需要在 Spark 3.2.1 中使用已经设计为 Spark 3.1 连接器的查询下推功能，有两种解决方法。首先可以升级连接器，以便支持 Spark 3.2.1。其次，可以禁用查询下推，这没问题，但需要付出性能损失。

在代码中禁用查询下推示例代码：

val spark = SparkSession.builder()
        .appName("ExampleApp")
        .config("spark.sql.adaptive.enabled", "true")
        .config("spark.sql.adaptive.join.enabled", "true")
        .config("spark.sql.adaptive.skewedJoin.enabled", "true")
        .config("spark.sql.adaptive.localShuffleReader.enabled", "true")
        .config("spark.sql.adaptive.coalescePartitions.enabled", "true")
        .config("spark.sql.adaptive.coalescePartitions.initialPartitionNum", "100")
        .config("spark.sql.legacy.timeParserPolicy", "legacy")
        .config("spark.sql.sources.orc.impl", "native")
        .config("spark.sql.sources.partitionOverwriteMode", "dynamic")
        .config("hive.exec.dynamic.partition", "true")
        .config("hive.exec.dynamic.partition.mode", "nonstrict")
        .config("hive.enforce.bucketing", "true")
        .enableHiveSupport()
        .getOrCreate()

spark.conf.set("spark.sql.cbo.enabled", "true")
spark.conf.set("spark.sql.planChangeLog.level", "info")
spark.conf.set("spark.sql.adaptive.localShuffleReader.fetchDataRetries", "1")
spark.conf.set("spark.sql.adaptive.localShuffleReader.fetchDataRetries.enabled", "true")
spark.conf.set("spark.sql.adaptive.localShuffleReader.maxNumBlocksToReadInBatch", "1024")
spark.conf.set("spark.sql.autoBroadcastJoinThreshold", "-1")

spark.conf.set("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension")
spark.conf.set("spark.delta.logStore.class", "org.apache.spark.sql.delta.storage.HDFSLogStore")