Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1515#discussion_r151832180
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/util/CommonUtil.scala
---
@@ -662,16 +663,18 @@ object CommonUtil {
val maxColumnsInt = getMaxColumnValue(maxColumns)
if (maxColumnsInt != null) {
if (columnCountInSchema >= maxColumnsInt) {
- sys.error(s"csv headers should be less than the max columns:
$maxColumnsInt")
+ CarbonException.analysisException(
+ s"csv headers should be less than the max columns:
$maxColumnsInt")
} else if (maxColumnsInt >
CSVInputFormat.THRESHOLD_MAX_NUMBER_OF_COLUMNS_FOR_PARSING) {
- sys.error(s"max columns cannot be greater than the threshold
value: ${
- CSVInputFormat.THRESHOLD_MAX_NUMBER_OF_COLUMNS_FOR_PARSING
- }")
+ CarbonException.analysisException(
+ s"max columns cannot be greater than the threshold value: ${
--- End diff --
Ok, I have modified it.
---
