def createStreamTableFunc(){
colName = msgTimemsgType`msgBody
colType = [TIMESTAMP,SYMBOL, BLOB]
messageTemp = streamTable(1000000:0, colName, colType)
enableTableShareAndPersistence(table=messageTemp, tableName="messageStream", asynWrite=true, compress=true, cacheSize=100000, retentionMinutes=1440, flushMode=0, preCache=0)
messageTemp = NULL
}
createStreamTableFunc()
go

注入数据

undef(`messageStream,SHARED);

再执行建表语句后报错