diff --git a/spark/src/test/scala/org/apache/spark/sql/delta/skipping/clustering/ClusteringColumnSuite.scala b/spark/src/test/scala/org/apache/spark/sql/delta/skipping/clustering/ClusteringColumnSuite.scala
index aa2182cbc55..da48dfa33df 100644
--- a/spark/src/test/scala/org/apache/spark/sql/delta/skipping/clustering/ClusteringColumnSuite.scala
+++ b/spark/src/test/scala/org/apache/spark/sql/delta/skipping/clustering/ClusteringColumnSuite.scala
@@ -63,7 +63,12 @@ class ClusteringColumnSuite extends ClusteredTableTestUtils with DeltaSQLCommand
       val e = intercept[AnalysisException] {
         ClusteringColumn(schema, "b")
       }
-      assert(e.getMessage.contains("Couldn't find column b"))
+      checkError(
+        e,
+        "DELTA_COLUMN_NOT_FOUND_IN_SCHEMA",
+        parameters = Map(
+          "columnName" -> "b",
+          "tableSchema" -> schema.treeString))
     }
   }
 }