diff --git a/cli/src/commands/put-stream.js b/cli/src/commands/put-stream.js
index d5ac55f4fe4a48d4590639215d972a0ae4da208a..2ab81bb8ae7e1153d4eeacbb76fcb64ab2b629d2 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 e69d928cd51c29f2d11f8ac99ad1dac384b7b5ec..4bd4d9e11d78d333c9f9867455865a46d1edc205 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);
         }
       });