我引入了sparkSql3.1.1 但是没有找到 org.apache.spark.sql.execution.datasources.CommitProtocol\

CommitProtocol 类是 Spark SQL 2.x 版本引入的，而在 Spark SQL 3.0+ 版本中已经被删除了。如果你需要使用提交协议相关的类，可以参考以下两种方式：

1. 如果你是从 Spark SQL 2.x 升级到 3.x，可以将你的代码中使用 CommitProtocol 的部分替换成对新的接口 StreamingWriteSupport 的使用，该接口是在 Spark SQL 3.0 中引入的，用于支持流式写入。例如：

import org.apache.spark.sql.streaming.StreamingQuery
import org.apache.spark.sql.streaming.StreamingQueryException
import org.apache.spark.sql.streaming.StreamingWriteSupport
import org.apache.spark.sql.SaveMode

val query: StreamingQuery = df.writeStream
  .format("console")
  .outputMode("append")
  .option("checkpointLocation", "/path/to/checkpoint")
  .option("commitProtocolClass", "org.apache.spark.sql.execution.streaming.sources.PythonForeachCommitProtocol")
  .start()

2. 如果你只是在 Spark SQL 3.x 中新建项目，可以考虑使用新的写入 API，例如 Delta Lake 或者 Apache Hudi。这些项目都提供了更强大的写入功能，并且支持 ACID 事务等特性。例如：

import org.apache.spark.sql.SaveMode
import org.apache.spark.sql.functions._

df.write.format("delta").mode("overwrite").save("/path/to/table")

希望能帮到你！