diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/text/TextSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/text/TextSuite.scala index 59e0e6a7cfa00..65f6b4fb3fee9 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/text/TextSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/text/TextSuite.scala @@ -71,8 +71,8 @@ class TextSuite extends QueryTest with SharedSQLContext { val tempDirPath = Utils.createTempDir().getAbsolutePath() testDf.write.option("compression", "illegal").mode(SaveMode.Overwrite).text(tempDirPath) } - assert(errMsg.getMessage === "Codec [illegal] is not available. " + - "Known codecs are bzip2, deflate, lz4, gzip, snappy.") + assert(errMsg.getMessage.contains("Codec [illegal] is not available. " + + "Known codecs are")) } private def testFile: String = {