From 89e8a6f868e154f45ea0c696a367cc64f1d92aa0 Mon Sep 17 00:00:00 2001
From: arshiam2 <arshiam2@illinois.edu>
Date: Sat, 1 Dec 2018 22:13:42 -0600
Subject: [PATCH] update
---
cli/src/commands/put-stream.js | 2 +-
sfds/index.js | 3 ---
2 files changed, 1 insertion(+), 4 deletions(-)
diff --git a/cli/src/commands/put-stream.js b/cli/src/commands/put-stream.js
index d5ac55f..2ab81bb 100644
--- a/cli/src/commands/put-stream.js
+++ b/cli/src/commands/put-stream.js
@@ -37,7 +37,7 @@ async function getCSVdata() {
];
let message = parsed.split(",")[3];
messages.push(message);
- if (messages.length == 10000) {
+ if (messages.length == 5000) {
allMessages.push(messages);
const body = { action: "START", state: messages[0] };
// console.log(body)
diff --git a/sfds/index.js b/sfds/index.js
index e69d928..4bd4d9e 100644
--- a/sfds/index.js
+++ b/sfds/index.js
@@ -410,13 +410,11 @@ app.post("/spout", function(req, res) {
});
app.get("/sink", function(req, res) {
- // console.log("bolt state: " +req.body.state)
if (results.length > 0) {
res.send(results.pop());
} else {
res.send("DONE");
}
- // res.send("IM A SINK");
});
@@ -438,7 +436,6 @@ setInterval(function sync() {
queue.push(json);
} else {
results.push(json.state)
- console.log(results.length)
console.log("result: " + json.state);
}
});
--
GitLab