Skip to content

X
xanadu
Commit 81e31051 authored by NILANJAN DAW's avatar NILANJAN DAW
Browse files
Options

fixed bug: RM not returning node address

parent a38a16ae
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
dispatch_system/dispatch_daemon/config.json
View file @ 81e31051
{"id":"192.168.0.105","master_node":"192.168.0.105"} {"id":"192.168.0.104","master_node":"192.168.0.105"}
\ No newline at end of file \ No newline at end of file
dispatch_system/dispatch_manager/rm.js
View file @ 81e31051
...@@ -18,7 +18,7 @@ let kafka = require('kafka-node'), ...@@ -18,7 +18,7 @@ let kafka = require('kafka-node'),
]) ])
function getAddress() { function getAddress() {
return Object.keys(workerNodes)[0];
} }
consumer.on('message', function (message) { consumer.on('message', function (message) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment