This commit is contained in:
dapan1121 2021-03-10 15:53:36 +08:00
parent 671492fb6d
commit 8e9c25cf86
1 changed files with 1 additions and 1 deletions

View File

@ -6246,7 +6246,7 @@ int32_t tscCheckCreateDbParams(SSqlCmd* pCmd, SCreateDbMsg* pCreate) {
return invalidSqlErrMsg(tscGetErrorMsgPayload(pCmd), msg); return invalidSqlErrMsg(tscGetErrorMsgPayload(pCmd), msg);
} }
val = htons(pCreate->partitions); val = (int16_t)htons(pCreate->partitions);
if (val != -1 && if (val != -1 &&
(val < TSDB_MIN_DB_PARTITON_OPTION || val > TSDB_MAX_DB_PARTITON_OPTION)) { (val < TSDB_MIN_DB_PARTITON_OPTION || val > TSDB_MAX_DB_PARTITON_OPTION)) {
snprintf(msg, tListLen(msg), "invalid topic option partition: %d valid range: [%d, %d]", val, snprintf(msg, tListLen(msg), "invalid topic option partition: %d valid range: [%d, %d]", val,