Commit e9cfe3d5 authored by Nilanjan Daw's avatar Nilanjan Daw

minor changes

parent 8b4f1d1a
{"id":"192.168.31.51","master_node":"10.129.6.5"} {"id":"10.196.6.51","master_node":"10.129.6.5"}
\ No newline at end of file \ No newline at end of file
...@@ -43,7 +43,7 @@ let kafka = require('kafka-node'), ...@@ -43,7 +43,7 @@ let kafka = require('kafka-node'),
{ topic: 'heartbeat' }, // receives heartbeat messages from workers, also acts as worker join message { topic: 'heartbeat' }, // receives heartbeat messages from workers, also acts as worker join message
{ topic: "deployed" }, // receives deployment confirmation from workers { topic: "deployed" }, // receives deployment confirmation from workers
{ topic: "removeWorker" }, // received when a executor environment is blown at the worker { topic: "removeWorker" }, // received when a executor environment is blown at the worker
{ topic: "RESPONSE_RM_2_DM_DUMMY" }, // receives deployment details from RM { topic: "RESPONSE_RM_2_DM" }, // receives deployment details from RM
{ topic: "hscale" } // receives signals for horizontal scaling { topic: "hscale" } // receives signals for horizontal scaling
], ],
[ [
...@@ -260,7 +260,7 @@ function dispatch() { ...@@ -260,7 +260,7 @@ function dispatch() {
let payloadToRM = [{ let payloadToRM = [{
topic: "request", // changing from REQUEST_DM_2_RM topic: "REQUEST_DM_2_RM", // changing from REQUEST_DM_2_RM
messages: JSON.stringify({ messages: JSON.stringify({
resource_id, resource_id,
"memory": 332, "memory": 332,
...@@ -443,7 +443,7 @@ consumer.on('message', function (message) { ...@@ -443,7 +443,7 @@ consumer.on('message', function (message) {
console.log("sent rm"); console.log("sent rm");
}) })
} else if (topic == "RESPONSE_RM_2_DM_DUMMY") { } else if (topic == "RESPONSE_RM_2_DM") {
logger.info("Response from RM: " + message); logger.info("Response from RM: " + message);
message = JSON.parse(message) message = JSON.parse(message)
......
...@@ -141,7 +141,7 @@ function compare(a, b) { ...@@ -141,7 +141,7 @@ function compare(a, b) {
} }
function branchChainPredictor(req, resourceMap) { function branchChainPredictor(req, resourceMap) {
console.log(req.headers['x-resource-id']); // console.log(req.headers['x-resource-id']);
if (req.headers['x-resource-id'] === undefined) { if (req.headers['x-resource-id'] === undefined) {
let functionHash = req.params.id let functionHash = req.params.id
......
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