Description
Prepend error messages by error class tags by extending the following method in SparkThrowableHelper:
def getMessage(errorClass: String, messageParameters: Array[String]): String = { val errorInfo = errorClassToInfoMap.getOrElse(errorClass, throw new IllegalArgumentException(s"Cannot find error class '$errorClass'")) String.format(errorInfo.messageFormat.replaceAll("<[a-zA-Z0-9_-]+>", "%s"), messageParameters: _*) }