diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index ad01585c..d9bc23e7 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -74,7 +74,7 @@ def get_buffer_output(nodename): select.select((instream,), (), (), 30) while not outdata or outdata[-1]: try: - chunk = instream.read(128) + chunk = os.read(instream.fileno(), 128) except IOError: chunk = None if chunk: