diff --git a/tests/pytest/tools/schemalessInsertPerformance.py b/tests/pytest/tools/schemalessInsertPerformance.py index 0dcbc5ffe20104555730fc8fc68cc378f85339e4..68802310a265e062ef01f4ec5303b722c0045198 100644 --- a/tests/pytest/tools/schemalessInsertPerformance.py +++ b/tests/pytest/tools/schemalessInsertPerformance.py @@ -190,7 +190,10 @@ class TDTestCase: def batchInsertTable(self, batch_list): for insert_list in batch_list: + print(threading.current_thread().name, "length=", len(insert_list)) + print(threading.current_thread().name, 'firstline', insert_list[0], 'lastline:', insert_list[-1]) self._conn.insert_lines(insert_list) + print(threading.current_thread().name, 'end') def genTableThread(self, thread_count=10): threads = list() @@ -228,7 +231,6 @@ class TDTestCase: self.createStb() table_list, end_list = self.splitTableList() batchInsertTableThread = self.threadInsertTable(end_list=end_list) - print(end_list) self.multiThreadRun(batchInsertTableThread) # print(end_list)