提交 77918a73 编写于 作者: A Adam Lee

Revert "gpload: log gpfdist outputs by default"

This reverts commit 64d150e9.
上级 2c68384e
...@@ -768,7 +768,7 @@ class CatThread(threading.Thread): ...@@ -768,7 +768,7 @@ class CatThread(threading.Thread):
line = self.fd.readline() line = self.fd.readline()
if line=='': if line=='':
break break
self.gpload.log(self.gpload.LOG, 'gpfdist: ' + line.strip('\n')) self.gpload.log(self.gpload.DEBUG, 'gpfdist: ' + line.strip('\n'))
else: else:
while 1: while 1:
retList = select.select( [self.fd] retList = select.select( [self.fd]
...@@ -784,7 +784,7 @@ class CatThread(threading.Thread): ...@@ -784,7 +784,7 @@ class CatThread(threading.Thread):
continue continue
if line=='': if line=='':
break break
self.gpload.log(self.gpload.LOG, 'gpfdist: ' + line.strip('\n')) self.gpload.log(self.gpload.DEBUG, 'gpfdist: ' + line.strip('\n'))
except Exception, e: except Exception, e:
# close fd so that not block the worker thread because of stdout/stderr pipe not finish/closed. # close fd so that not block the worker thread because of stdout/stderr pipe not finish/closed.
self.fd.close() self.fd.close()
...@@ -1324,7 +1324,7 @@ class gpload: ...@@ -1324,7 +1324,7 @@ class gpload:
if level <= self.options.qv: if level <= self.options.qv:
sys.stdout.write(str) sys.stdout.write(str)
if level <= self.options.qv or level <= self.LOG: if level <= self.options.qv or level <= self.INFO:
try: try:
self.logfile.write(str) self.logfile.write(str)
self.logfile.flush() self.logfile.flush()
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册