tdLog.info("restart taosd to ensure that the data falls into the disk")
tdLog.info("restart taosd to ensure that the data falls into the disk")
# tdDnodes.stop(1)
# tdDnodes.stop(1)
# tdDnodes.start(1)
# tdDnodes.start(1)
...
@@ -93,11 +93,11 @@ class TDTestCase:
...
@@ -93,11 +93,11 @@ class TDTestCase:
paraDict['vgroups']=self.vgroups
paraDict['vgroups']=self.vgroups
paraDict['ctbNum']=self.ctbNum
paraDict['ctbNum']=self.ctbNum
paraDict['rowsPerTbl']=self.rowsPerTbl
paraDict['rowsPerTbl']=self.rowsPerTbl
topicNameList=['topic1']
topicNameList=['topic1']
expectRowsList=[]
expectRowsList=[]
tmqCom.initConsumerTable()
tmqCom.initConsumerTable()
tdLog.info("create topics from stb with filter")
tdLog.info("create topics from stb with filter")
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+9379)
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+9379)
...
@@ -105,7 +105,7 @@ class TDTestCase:
...
@@ -105,7 +105,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+9379)
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+9379)
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
...
@@ -178,7 +178,7 @@ class TDTestCase:
...
@@ -178,7 +178,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
sqlString="create topic %s as %s"%(topicNameList[0],queryString)