Skip to content

Commit 882e321

Browse files
committed
Review comments
1 parent 84241e0 commit 882e321

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

project/MimaExcludes.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,8 @@ object MimaExcludes {
3636

3737
// Exclude rules for 3.2.x
3838
lazy val v32excludes = v31excludes ++ Seq(
39+
// [SPARK-33808][SQL] DataSource V2: Build logical writes in the optimizer
40+
ProblemFilters.exclude[MissingClassProblem]("org.apache.spark.sql.connector.write.V1WriteBuilder")
3941
)
4042

4143
// Exclude rules for 3.1.x

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Strategy.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ class DataSourceV2Strategy(session: SparkSession) extends Strategy with Predicat
204204
case v2Write =>
205205
throw new AnalysisException(
206206
s"Table ${v1.name} declares ${TableCapability.V1_BATCH_WRITE} capability but " +
207-
s"${v2Write.getClass} is not an instance of ${classOf[V1Write]}")
207+
s"${v2Write.getClass.getName} is not an instance of ${classOf[V1Write].getName}")
208208
}
209209

210210
case AppendData(r @ DataSourceV2Relation(v2: SupportsWrite, _, _, _, _), query, writeOptions,
@@ -220,7 +220,7 @@ class DataSourceV2Strategy(session: SparkSession) extends Strategy with Predicat
220220
case v2Write =>
221221
throw new AnalysisException(
222222
s"Table ${v1.name} declares ${TableCapability.V1_BATCH_WRITE} capability but " +
223-
s"${v2Write.getClass} is not an instance of ${classOf[V1Write]}")
223+
s"${v2Write.getClass.getName} is not an instance of ${classOf[V1Write].getName}")
224224
}
225225

226226
case OverwriteByExpression(r @ DataSourceV2Relation(v2: SupportsWrite, _, _, _, _), _, query,

0 commit comments

Comments
 (0)