2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-04-13 12:21:30 +00:00

Merge pull request #37 from jufm/stringfix

Fix encoded string problem in InputNTPServer
This commit is contained in:
Jarrod Johnson
2015-10-13 14:56:55 -04:00

View File

@@ -655,7 +655,7 @@ class InputNTPServer(ConfluentInputMessage):
raise exc.InvalidArgumentException(
'This only supports per-node input')
for node in nodes:
self.inputbynode[node] = inputdata['server']
self.inputbynode[node] = str(inputdata['server'])
def ntp_server(self, node):
return self.inputbynode[node]