fix: error in schemaless_insert if insert with multi threads
This commit is contained in:
parent
f31ec1d1b5
commit
48b487dd9d
|
@ -2289,6 +2289,8 @@ static int32_t smlParseLine(SSmlHandle *info, char* lines[], int numLines){
|
||||||
|
|
||||||
static int smlProcess(SSmlHandle *info, char* lines[], int numLines) {
|
static int smlProcess(SSmlHandle *info, char* lines[], int numLines) {
|
||||||
int32_t code = TSDB_CODE_SUCCESS;
|
int32_t code = TSDB_CODE_SUCCESS;
|
||||||
|
int32_t retryNum = 0;
|
||||||
|
|
||||||
info->cost.parseTime = taosGetTimestampUs();
|
info->cost.parseTime = taosGetTimestampUs();
|
||||||
|
|
||||||
code = smlParseLine(info, lines, numLines);
|
code = smlParseLine(info, lines, numLines);
|
||||||
|
@ -2303,7 +2305,6 @@ static int smlProcess(SSmlHandle *info, char* lines[], int numLines) {
|
||||||
|
|
||||||
info->cost.schemaTime = taosGetTimestampUs();
|
info->cost.schemaTime = taosGetTimestampUs();
|
||||||
|
|
||||||
int32_t retryNum = 0;
|
|
||||||
do{
|
do{
|
||||||
code = smlModifyDBSchemas(info);
|
code = smlModifyDBSchemas(info);
|
||||||
if (code == 0) break;
|
if (code == 0) break;
|
||||||
|
|
Loading…
Reference in New Issue