update

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)

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);
         }
       });