All the work is done by only 1 node
Closed this issue · 2 comments
meijun commented
I started 3 agents, but only the third agent worked. Is there any wrong with my code? And I wonder why there are some empty outputs at the end of log outputs. Thanks for help~
package main
import (
"flag"
"github.com/chrislusf/glow/flow"
_ "github.com/chrislusf/glow/driver"
"log"
"os"
)
func main() {
flag.Parse()
cnt := 1 << 6
tasks := make([]int, cnt)
for i := range tasks {
tasks[i] = 1 << 32
}
log.Println("Begin", Hostname())
flow.New().Slice(tasks).Partition(cnt).Map(func(tot int) {
i := 0
for ; i < tot; i++ {}
log.Println(i, Hostname())
}).Run()
log.Println("End", Hostname())
}
func Hostname() string {
name, err := os.Hostname()
if err != nil {
log.Fatalf("Hostname: %v\n", err)
}
return name
}Outputs:
2017/03/02 23:13:33 Begin admin
2017/03/02 23:13:33 localhost:8930 allocated 1 executors.
2017/03/02 23:13:33 localhost:8930 allocated 1 executors.
2017/03/02 23:13:33 localhost:8930 allocated 6 executors.
2017/03/02 23:13:33 localhost:8930 allocated 57 executors.
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.1:8931>2017/03/02 23:12:25 Begin node1
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.1:8931>2017/03/02 23:12:25 End node1
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 Begin node3
10.10.10.3:8931>2017/03/02 23:12:25 End node3
10.10.10.3:8931>2017/03/02 23:12:27 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:28 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:30 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:31 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:33 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:34 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:36 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:38 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:39 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:41 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:42 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:44 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:46 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:47 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:49 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:50 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:52 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:53 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:55 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:56 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:58 4294967296 node3
10.10.10.3:8931>2017/03/02 23:12:59 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:01 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:02 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:04 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:06 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:07 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:09 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:10 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:12 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:13 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:15 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:16 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:18 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:19 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:21 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:23 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:24 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:26 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:27 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:29 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:30 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:32 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:33 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:35 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:37 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:38 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:40 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:41 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:43 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:44 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:46 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:47 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:49 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:50 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:52 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:54 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:55 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:57 4294967296 node3
10.10.10.3:8931>2017/03/02 23:13:58 4294967296 node3
10.10.10.3:8931>2017/03/02 23:14:00 4294967296 node3
10.10.10.3:8931>2017/03/02 23:14:01 4294967296 node3
10.10.10.3:8931>2017/03/02 23:14:03 4294967296 node3
10.10.10.3:8931>2017/03/02 23:14:04 4294967296 node3
10.10.10.3:8931>2017/03/02 23:14:04 End node3
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
10.10.10.3:8931
2017/03/02 23:15:12 End admin
chrislusf commented
I am not remembering the details of glow now. Please use gleam. It also has a pure go support.
meijun commented
Thanks.