From cb631ee40f8d1f7180fb569a8f52fe836a0dbef5 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 27 Aug 2014 14:29:53 -0400 Subject: [PATCH] Fix issue with client state corruption on errored console start Previously, the console start path would bail out without consuming the '_requestdone' message. Correct this by reading until requestdone is seen as required by protocol. --- confluent_client/bin/confetty | 2 ++ 1 file changed, 2 insertions(+) diff --git a/confluent_client/bin/confetty b/confluent_client/bin/confetty index 0977621e..dfc70582 100755 --- a/confluent_client/bin/confetty +++ b/confluent_client/bin/confetty @@ -293,6 +293,8 @@ def do_command(command, server): if 'errorcode' in status: exitcode = status['errorcode'] sys.stderr.write('Error: ' + status['error'] + '\n') + while '_requestdone' not in status: + status = tlvdata.recv(session.connection) return print '[console session started]' startconsole(nodename)