in fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/WorkloadGroup.java [263:532]
private static void checkProperties(Map<String, String> properties) throws DdlException {
for (String propertyName : properties.keySet()) {
if (!ALL_PROPERTIES_NAME.contains(propertyName)) {
throw new DdlException("Property " + propertyName + " is not supported.");
}
}
if (properties.containsKey(CPU_SHARE)) {
String inputValue = properties.get(CPU_SHARE);
try {
int cpuShareI = Integer.parseInt(inputValue);
if (cpuShareI <= 0 && cpuShareI != -1) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + CPU_SHARE + " value is -1 or a positive integer, but input value is "
+ inputValue);
}
}
if (properties.containsKey(CPU_HARD_LIMIT)) {
String inputValue = properties.get(CPU_HARD_LIMIT);
String cpuHardLimit = inputValue;
try {
boolean endWithSign = false;
if (cpuHardLimit.endsWith("%")) {
cpuHardLimit = cpuHardLimit.substring(0, cpuHardLimit.length() - 1);
endWithSign = true;
}
int intVal = Integer.parseInt(cpuHardLimit);
if (endWithSign && intVal == -1) {
throw new NumberFormatException();
}
if (!(intVal >= 1 && intVal <= 100) && -1 != intVal) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + WorkloadGroup.CPU_HARD_LIMIT
+ " value is -1 or a positive integer between 1 and 100, but input value is "
+ inputValue);
}
}
if (properties.containsKey(MEMORY_LIMIT)) {
String memoryLimitStr = properties.get(MEMORY_LIMIT);
if (!memoryLimitStr.endsWith("%") && !"-1".equals(memoryLimitStr)) {
throw new DdlException(
MEMORY_LIMIT + " requires a percentage value which ends with a '%' or -1, but input value is "
+ memoryLimitStr);
}
if (!"-1".equals(memoryLimitStr)) {
try {
double memLimitD = Double.parseDouble(memoryLimitStr.substring(0, memoryLimitStr.length() - 1));
if (memLimitD <= 0) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException("The allowed " + MEMORY_LIMIT
+ " value is a positive floating point number, but input value is " + memoryLimitStr);
}
}
}
if (properties.containsKey(WRITE_BUFFER_RATIO)) {
String writeBufSizeStr = properties.get(WRITE_BUFFER_RATIO);
String memLimitErr = WRITE_BUFFER_RATIO + " " + writeBufSizeStr
+ " requires a positive int number.";
if (writeBufSizeStr.endsWith("%")) {
writeBufSizeStr = writeBufSizeStr.substring(0, writeBufSizeStr.length() - 1);
}
try {
if (Integer.parseInt(writeBufSizeStr) < 0) {
throw new DdlException(memLimitErr);
}
} catch (NumberFormatException e) {
if (LOG.isDebugEnabled()) {
LOG.debug(memLimitErr, e);
}
throw new DdlException(memLimitErr);
}
}
if (properties.containsKey(ENABLE_MEMORY_OVERCOMMIT)) {
String inputValue = properties.get(ENABLE_MEMORY_OVERCOMMIT);
String value = inputValue.toLowerCase();
if (!("true".equals(value) || "false".equals(value))) {
throw new DdlException(
"The value of '" + ENABLE_MEMORY_OVERCOMMIT + "' must be true or false. but input value is "
+ inputValue);
}
}
if (properties.containsKey(SLOT_MEMORY_POLICY)) {
String value = properties.get(SLOT_MEMORY_POLICY).toLowerCase();
if (!AVAILABLE_SLOT_MEMORY_POLICY_VALUES.contains(value)) {
throw new DdlException("The value of '" + SLOT_MEMORY_POLICY
+ "' must be one of none, fixed, dynamic.");
}
}
if (properties.containsKey(SCAN_THREAD_NUM)) {
String value = properties.get(SCAN_THREAD_NUM);
try {
int intValue = Integer.parseInt(value);
if (intValue <= 0 && intValue != -1) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + SCAN_THREAD_NUM + " value is -1 or a positive integer. but input value is "
+ value);
}
}
int maxRemoteScanNum = -1;
if (properties.containsKey(MAX_REMOTE_SCAN_THREAD_NUM)) {
String value = properties.get(MAX_REMOTE_SCAN_THREAD_NUM);
try {
int intValue = Integer.parseInt(value);
if (intValue <= 0 && intValue != -1) {
throw new NumberFormatException();
}
maxRemoteScanNum = intValue;
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + MAX_REMOTE_SCAN_THREAD_NUM
+ " value is -1 or a positive integer. but input value is " + value);
}
}
int minRemoteScanNum = -1;
if (properties.containsKey(MIN_REMOTE_SCAN_THREAD_NUM)) {
String value = properties.get(MIN_REMOTE_SCAN_THREAD_NUM);
try {
int intValue = Integer.parseInt(value);
if (intValue <= 0 && intValue != -1) {
throw new NumberFormatException();
}
minRemoteScanNum = intValue;
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + MIN_REMOTE_SCAN_THREAD_NUM
+ " value is -1 or a positive integer. but input value is " + value);
}
}
if ((maxRemoteScanNum == -1 && minRemoteScanNum != -1) || (maxRemoteScanNum != -1 && minRemoteScanNum == -1)) {
throw new DdlException(MAX_REMOTE_SCAN_THREAD_NUM + " and " + MIN_REMOTE_SCAN_THREAD_NUM
+ " must be specified simultaneously");
} else if (maxRemoteScanNum < minRemoteScanNum) {
throw new DdlException(MAX_REMOTE_SCAN_THREAD_NUM + " must bigger or equal " + MIN_REMOTE_SCAN_THREAD_NUM);
}
// check queue property
if (properties.containsKey(MAX_CONCURRENCY)) {
String inputValue = properties.get(MAX_CONCURRENCY);
try {
if (Integer.parseInt(inputValue) < 0) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + MAX_CONCURRENCY
+ " value is an integer greater than or equal to 0, but input value is "
+ inputValue);
}
}
if (properties.containsKey(MAX_QUEUE_SIZE)) {
String inputValue = properties.get(MAX_QUEUE_SIZE);
try {
if (Integer.parseInt(inputValue) < 0) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + MAX_QUEUE_SIZE
+ " value is an integer greater than or equal to 0, but input value is "
+ inputValue);
}
}
if (properties.containsKey(QUEUE_TIMEOUT)) {
String inputValue = properties.get(QUEUE_TIMEOUT);
try {
if (Integer.parseInt(inputValue) < 0) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + QUEUE_TIMEOUT
+ " value is an integer greater than or equal to 0, but input value is "
+ inputValue);
}
}
int lowWaterMark = MEMORY_LOW_WATERMARK_DEFAULT_VALUE;
if (properties.containsKey(MEMORY_LOW_WATERMARK)) {
String lowVal = properties.get(MEMORY_LOW_WATERMARK);
if (lowVal.endsWith("%")) {
lowVal = lowVal.substring(0, lowVal.length() - 1);
}
try {
int intValue = Integer.parseInt(lowVal);
if ((intValue < 1 || intValue > 100)) {
throw new NumberFormatException();
}
lowWaterMark = intValue;
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + MEMORY_LOW_WATERMARK
+ " value is an integer value between 1 and 100, but input value is "
+ lowVal);
}
}
int highWaterMark = MEMORY_HIGH_WATERMARK_DEFAULT_VALUE;
if (properties.containsKey(MEMORY_HIGH_WATERMARK)) {
String highVal = properties.get(MEMORY_HIGH_WATERMARK);
if (highVal.endsWith("%")) {
highVal = highVal.substring(0, highVal.length() - 1);
}
try {
int intValue = Integer.parseInt(highVal);
if ((intValue < 1 || intValue > 100)) {
throw new NumberFormatException();
}
highWaterMark = intValue;
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + MEMORY_HIGH_WATERMARK
+ " value is an integer value between 1 and 100, but input value is "
+ highVal);
}
}
if (lowWaterMark > highWaterMark) {
throw new DdlException(MEMORY_HIGH_WATERMARK + "(" + highWaterMark + ") should bigger than "
+ MEMORY_LOW_WATERMARK + "(" + lowWaterMark + ")");
}
if (properties.containsKey(READ_BYTES_PER_SECOND)) {
String readBytesVal = properties.get(READ_BYTES_PER_SECOND);
try {
long longVal = Long.parseLong(readBytesVal);
if (longVal <= 0 && longVal != -1) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException(
"The allowed " + READ_BYTES_PER_SECOND
+ " value should be -1 or an positive integer, but input value is "
+ readBytesVal);
}
}
if (properties.containsKey(REMOTE_READ_BYTES_PER_SECOND)) {
String readBytesVal = properties.get(REMOTE_READ_BYTES_PER_SECOND);
try {
long longVal = Long.parseLong(readBytesVal);
if (longVal <= 0 && longVal != -1) {
throw new NumberFormatException();
}
} catch (NumberFormatException e) {
throw new DdlException("The allowed " + REMOTE_READ_BYTES_PER_SECOND
+ " value should be -1 or an positive integer, but input value is " + readBytesVal);
}
}
}