diff --git a/dataset/demo.txt b/dataset/demo.txt
new file mode 100644
index 0000000000000000000000000000000000000000..fba2bc9bbe60bc933e978c352f91e955d2728141
--- /dev/null
+++ b/dataset/demo.txt
@@ -0,0 +1,201 @@
+0
+1
+2
+3
+4
+5
+6
+7
+8
+9
+10
+11
+12
+13
+14
+15
+16
+17
+18
+19
+20
+21
+22
+23
+24
+25
+26
+27
+28
+29
+30
+31
+32
+33
+34
+35
+36
+37
+38
+39
+40
+41
+42
+43
+44
+45
+46
+47
+48
+49
+50
+51
+52
+53
+54
+55
+56
+57
+58
+59
+60
+61
+62
+63
+64
+65
+66
+67
+68
+69
+70
+71
+72
+73
+74
+75
+76
+77
+78
+79
+80
+81
+82
+83
+84
+85
+86
+87
+88
+89
+90
+91
+92
+93
+94
+95
+96
+97
+98
+99
+100
+101
+102
+103
+104
+105
+106
+107
+108
+109
+110
+111
+112
+113
+114
+115
+116
+117
+118
+119
+120
+121
+122
+123
+124
+125
+126
+127
+128
+129
+130
+131
+132
+133
+134
+135
+136
+137
+138
+139
+140
+141
+142
+143
+144
+145
+146
+147
+148
+149
+150
+151
+152
+153
+154
+155
+156
+157
+158
+159
+160
+161
+162
+163
+164
+165
+166
+167
+168
+169
+170
+171
+172
+173
+174
+175
+176
+177
+178
+179
+180
+181
+182
+183
+184
+185
+186
+187
+188
+189
+190
+191
+192
+193
+194
+195
+196
+197
+198
+199
+200
\ No newline at end of file
diff --git a/src/crane/crane_master.go b/src/crane/crane_master.go
index 8a3b307a8d24eeca6683544dcff7887159aaea5b..60b625ab8c4a7414ae758c505f3e84a6a85034e1 100644
--- a/src/crane/crane_master.go
+++ b/src/crane/crane_master.go
@@ -372,7 +372,7 @@ func runSpout() {
 	fmt.Println("New job started running...")
 	scanner := bufio.NewScanner(file)
 	for scanner.Scan() {
-		// time.Sleep(shared.CraneSpoutInterval)
+		time.Sleep(shared.CraneSpoutInterval)
 		// activeListMux.Lock()
 		// fmt.Println(activeList)
 		// activeListMux.Unlock()
diff --git a/src/crane/worker.go b/src/crane/worker.go
index a95a2faec8f38e551cf480b1a0ea4e24c97200d8..c7ab7e3a54ab8365f3df408779775a32e5b2c142 100644
--- a/src/crane/worker.go
+++ b/src/crane/worker.go
@@ -111,7 +111,7 @@ func handleWorkerRequest(conn net.Conn) {
 			gobDecoder.Decode(data)
 			// Write ack response
 			//conn.Write([]byte("Ack"))
-			processData(*data)
+			go processData(*data)
 		}
 	}
 	conn.Close()