diff --git a/confluent_client/bin/noderun b/confluent_client/bin/noderun index 10ee3975..0ecd7626 100755 --- a/confluent_client/bin/noderun +++ b/confluent_client/bin/noderun @@ -97,6 +97,7 @@ def run(): pernodeout[node] = [] pernodeout[node].append(data) else: + data = client.stringify(data) if options.nonodeprefix: sys.stderr.write(data) else: @@ -114,6 +115,7 @@ def run(): run_cmdv(node, cmdv, all, pipedesc) for node in sortutil.natural_sort(pernodeout): for line in pernodeout[node]: + line = client.stringify(line) if options.nonodeprefix: sys.stdout.write(line) else: diff --git a/confluent_client/bin/nodeshell b/confluent_client/bin/nodeshell index d0619f70..551a9e1e 100755 --- a/confluent_client/bin/nodeshell +++ b/confluent_client/bin/nodeshell @@ -98,6 +98,7 @@ def run(): pernodeout[node] = [] pernodeout[node].append(data) else: + data = client.stringify(data) if options.nonodeprefix: sys.stderr.write(data) else: @@ -115,6 +116,7 @@ def run(): run_cmdv(node, cmdv, all, pipedesc) for node in sortutil.natural_sort(pernodeout): for line in pernodeout[node]: + line = client.stringify(line) if options.nonodeprefix: sys.stdout.write(line) else: