提交 c8a44d42 编写于 作者: M Marbin Tan 提交者: GitHub

Remove timeout logic from analyzedb (#1537)

* Timeout was removed from the WorkerPool on commit
  c7dfcc45
上级 01a6414b
...@@ -563,7 +563,7 @@ class AnalyzeDb(Operation): ...@@ -563,7 +563,7 @@ class AnalyzeDb(Operation):
ret.append(tup) ret.append(tup)
return ret return ret
def _write_back(self, curr_ao_state, curr_last_op, prev_ao_state, prev_last_op, heap_partitions, def _write_back(self, curr_ao_state, curr_last_op, prev_ao_state, prev_last_op, heap_partitions,
input_col_dict, prev_col_dict, root_partition_col_dict, is_full, dirty_partitions, target_list): input_col_dict, prev_col_dict, root_partition_col_dict, is_full, dirty_partitions, target_list):
...@@ -1158,10 +1158,9 @@ class AnalyzeWorker(Thread): ...@@ -1158,10 +1158,9 @@ class AnalyzeWorker(Thread):
name=None name=None
logger=None logger=None
def __init__(self,name,pool,timeout=0.05): def __init__(self,name,pool):
self.name=name self.name=name
self.pool=pool self.pool=pool
self.timeout=timeout
self.logger=logger self.logger=logger
self.stoprequest = threading.Event() self.stoprequest = threading.Event()
Thread.__init__(self) Thread.__init__(self)
...@@ -1169,7 +1168,7 @@ class AnalyzeWorker(Thread): ...@@ -1169,7 +1168,7 @@ class AnalyzeWorker(Thread):
def run(self): def run(self):
while not self.stoprequest.isSet(): while not self.stoprequest.isSet():
try: try:
self.cmd = self.pool.getNextWorkItem(timeout=self.timeout) self.cmd = self.pool.getNextWorkItem()
if self.cmd is not None: if self.cmd is not None:
# tablename = self.cmd.cmdStr.split()[-1][:-1] # tablename = self.cmd.cmdStr.split()[-1][:-1]
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册