check error message

apache · Aug 12, 2019 · 621ee0e · 621ee0e
1 parent b64f9c1
commit 621ee0e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/external/avro/src/test/scala/org/apache/spark/sql/avro/AvroCatalystDataConversionSuite.scala b/external/avro/src/test/scala/org/apache/spark/sql/avro/AvroCatalystDataConversionSuite.scala
@@ -227,13 +227,14 @@ class AvroCatalystDataConversionSuite extends SparkFunSuite
         jsonFormatSchema,
         options = Map.empty),
       data.eval())
-    intercept[SparkException] {
+    val message = intercept[SparkException] {
       AvroDataToCatalyst(
         CatalystDataToAvro(
           data,
           None),
         jsonFormatSchema,
         options = Map.empty).eval()
-    }
+    }.getMessage
+    assert(message.contains("Malformed records are detected in record parsing."))
   }
 }