ajantha-bhat commented on a change in pull request #4020:
URL: https://github.com/apache/carbondata/pull/4020#discussion_r532362493
##########
File path:
integration/spark/src/main/scala/org/apache/carbondata/spark/util/CommonUtil.scala
##########
@@ -292,6 +293,33 @@ object CommonUtil {
}
}
+ /**
+ * This method will validate the minor compaction size specified by the user
+ * the property is used while doing minor compaction
+ *
+ * @param tableProperties
+ */
+ def validateMinorCompactionSize(tableProperties: Map[String, String]): Unit
= {
+ var minorCompactionSize: Integer = 0
+ val tblPropName = CarbonCommonConstants.TABLE_MINOR_COMPACTION_SIZE
+ if (tableProperties.get(tblPropName).isDefined) {
+ val minorCompactionSizeStr: String =
+ parsePropertyValueStringInMB(tableProperties(tblPropName))
+ try {
+ minorCompactionSize = Integer.parseInt(minorCompactionSizeStr)
+ } catch {
+ case e: NumberFormatException =>
+ throw new MalformedCarbonCommandException(s"Invalid $tblPropName
value found: " +
+ s"$minorCompactionSizeStr, only int value greater than 0 is
supported.")
Review comment:
0 is also supported right ?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
