fix:error in auto create table for taosX
This commit is contained in:
parent
a1257090e2
commit
0a497f6f21
|
@ -653,15 +653,15 @@ static int32_t meta_msg_process(TAOS_RES* msg, SThreadInfo* pInfo, int32_t msgIn
|
||||||
int32_t code = tmq_get_raw(msg, &raw);
|
int32_t code = tmq_get_raw(msg, &raw);
|
||||||
|
|
||||||
if(code == TSDB_CODE_SUCCESS){
|
if(code == TSDB_CODE_SUCCESS){
|
||||||
int retCode = queryDB(pInfo->taos, "use metadb");
|
// int retCode = queryDB(pInfo->taos, "use metadb");
|
||||||
if (retCode != 0) {
|
// if (retCode != 0) {
|
||||||
taosFprintfFile(g_fp, "error when use metadb\n");
|
// taosFprintfFile(g_fp, "error when use metadb\n");
|
||||||
taosCloseFile(&g_fp);
|
// taosCloseFile(&g_fp);
|
||||||
exit(-1);
|
// exit(-1);
|
||||||
}
|
// }
|
||||||
taosFprintfFile(g_fp, "raw:%p\n", &raw);
|
// taosFprintfFile(g_fp, "raw:%p\n", &raw);
|
||||||
|
//
|
||||||
tmq_write_raw(pInfo->taos, raw);
|
// tmq_write_raw(pInfo->taos, raw);
|
||||||
}
|
}
|
||||||
|
|
||||||
char* result = tmq_get_json_meta(msg);
|
char* result = tmq_get_json_meta(msg);
|
||||||
|
|
Loading…
Reference in New Issue