diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h index c9428504b81e45e63f723fce1182d725e4d34c26..187b7393e6d9dfef9ef3abec9abafe83e208d55b 100644 --- a/src/client/inc/tsclient.h +++ b/src/client/inc/tsclient.h @@ -42,7 +42,6 @@ extern "C" { struct SSqlInfo; #define KvRowNColsThresh 128 // default 128 -#define KVRowRatio 0.9 // for NonVarType, we get value from SDataRow directly, while needs readdressing for SKVRow typedef void (*__async_cb_func_t)(void *param, TAOS_RES *tres, int32_t numOfRows); diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c index d665e2100a0f45d99883630ba8590cbeb07ebd9c..9d50c1c62be15c2cebe339a9d51927ae615dcdfb 100644 --- a/src/client/src/tscParseInsert.c +++ b/src/client/src/tscParseInsert.c @@ -901,7 +901,7 @@ int tsParseOneRow(char **str, STableDataBlocks *pDataBlocks, int16_t timePrec, i dataRowLen += dataRowDeltaColLen; } - if (kvRowLen < dataRowLen * KVRowRatio) { + if (kvRowLen < dataRowLen) { payloadSetType(payload, SMEM_ROW_KV); } else { payloadSetType(payload, SMEM_ROW_DATA);