fix: failed to update json idx
This commit is contained in:
		
							parent
							
								
									e75f14b98b
								
							
						
					
					
						commit
						f35ba2a85e
					
				| 
						 | 
					@ -103,7 +103,7 @@ static int metaSaveJsonVarToIdx(SMeta *pMeta, const SMetaEntry *pCtbEntry, const
 | 
				
			||||||
  tIndexJsonPut(pMeta->pTagIvtIdx, terms, tuid);
 | 
					  tIndexJsonPut(pMeta->pTagIvtIdx, terms, tuid);
 | 
				
			||||||
  indexMultiTermDestroy(terms);
 | 
					  indexMultiTermDestroy(terms);
 | 
				
			||||||
#endif
 | 
					#endif
 | 
				
			||||||
  return -1;
 | 
					  return 0;
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
int metaCreateSTable(SMeta *pMeta, int64_t version, SVCreateStbReq *pReq) {
 | 
					int metaCreateSTable(SMeta *pMeta, int64_t version, SVCreateStbReq *pReq) {
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -38,7 +38,7 @@ typedef struct SIFParam {
 | 
				
			||||||
  col_id_t      colId;
 | 
					  col_id_t      colId;
 | 
				
			||||||
  int64_t       suid;  // add later
 | 
					  int64_t       suid;  // add later
 | 
				
			||||||
  char          dbName[TSDB_DB_NAME_LEN];
 | 
					  char          dbName[TSDB_DB_NAME_LEN];
 | 
				
			||||||
  char          colName[TSDB_COL_NAME_LEN];
 | 
					  char          colName[TSDB_COL_NAME_LEN * 2 + 4];
 | 
				
			||||||
 | 
					
 | 
				
			||||||
  SIndexMetaArg arg;
 | 
					  SIndexMetaArg arg;
 | 
				
			||||||
} SIFParam;
 | 
					} SIFParam;
 | 
				
			||||||
| 
						 | 
					@ -171,6 +171,7 @@ static int32_t sifInitJsonParam(SNode *node, SIFParam *param, SIFCtx *ctx) {
 | 
				
			||||||
  param->colId = l->colId;
 | 
					  param->colId = l->colId;
 | 
				
			||||||
  param->colValType = l->node.resType.type;
 | 
					  param->colValType = l->node.resType.type;
 | 
				
			||||||
  memcpy(param->dbName, l->dbName, sizeof(l->dbName));
 | 
					  memcpy(param->dbName, l->dbName, sizeof(l->dbName));
 | 
				
			||||||
 | 
					
 | 
				
			||||||
  sprintf(param->colName, "%s_%s", l->colName, r->literal);
 | 
					  sprintf(param->colName, "%s_%s", l->colName, r->literal);
 | 
				
			||||||
  param->colValType = r->typeData;
 | 
					  param->colValType = r->typeData;
 | 
				
			||||||
  return 0;
 | 
					  return 0;
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue