scheduler is now an instance of ProactiveClusterwideCapFCFS
This commit is contained in:
parent
522b606165
commit
6d0a3f8a90
1 changed files with 4 additions and 4 deletions
|
@ -1,9 +1,9 @@
|
||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"bitbucket.org/bingcloud/electron/def"
|
"bitbucket.org/sunybingcloud/electron/def"
|
||||||
"bitbucket.org/bingcloud/electron/pcp"
|
"bitbucket.org/sunybingcloud/electron/pcp"
|
||||||
"bitbucket.org/bingcloud/electron/schedulers"
|
"bitbucket.org/sunybingcloud/electron/schedulers"
|
||||||
"flag"
|
"flag"
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/golang/protobuf/proto"
|
"github.com/golang/protobuf/proto"
|
||||||
|
@ -56,7 +56,7 @@ func main() {
|
||||||
fmt.Println(task)
|
fmt.Println(task)
|
||||||
}
|
}
|
||||||
|
|
||||||
scheduler := schedulers.NewFirstFit(tasks, *ignoreWatts)
|
scheduler := schedulers.NewProactiveClusterwideCapFCFS(tasks, *ignoreWatts)
|
||||||
driver, err := sched.NewMesosSchedulerDriver(sched.DriverConfig{
|
driver, err := sched.NewMesosSchedulerDriver(sched.DriverConfig{
|
||||||
Master: *master,
|
Master: *master,
|
||||||
Framework: &mesos.FrameworkInfo{
|
Framework: &mesos.FrameworkInfo{
|
||||||
|
|
Reference in a new issue