fix:modify checkFileContent if one is empty
This commit is contained in:
parent
54a414a934
commit
985a238242
|
@ -468,10 +468,12 @@ class TMQCom:
|
||||||
dstSplit = dst.split(',')
|
dstSplit = dst.split(',')
|
||||||
srcSplit = src.split(',')
|
srcSplit = src.split(',')
|
||||||
|
|
||||||
if len(dstSplit) != len(srcSplit):
|
|
||||||
tdLog.exit("consumerId %d consume rows len is not match the rows by direct query"%consumerId)
|
|
||||||
if not dst or not src:
|
if not dst or not src:
|
||||||
break
|
break
|
||||||
|
if len(dstSplit) != len(srcSplit):
|
||||||
|
tdLog.exit("consumerId %d consume rows len is not match the rows by direct query,len(dstSplit):%d != len(srcSplit):%d, dst:%s, src:%s"
|
||||||
|
%(consumerId, len(dstSplit), len(srcSplit), dst, src))
|
||||||
|
|
||||||
for i in range(len(dstSplit)):
|
for i in range(len(dstSplit)):
|
||||||
if srcSplit[i] != dstSplit[i]:
|
if srcSplit[i] != dstSplit[i]:
|
||||||
srcFloat = float(srcSplit[i])
|
srcFloat = float(srcSplit[i])
|
||||||
|
|
Loading…
Reference in New Issue