Aditi, driver->stop() will shutdown the schedulerDriver, and passing in 'true' just means that it doesn't shutdown the framework within Mesos and kill its tasks. You will have to manually create a new SchedulerDriver for it to reregister with Mesos, whether you do that within your still-running scheduler, or by shutting down and restarting the scheduler. Note that you will need to reregister with the same frameworkId to reconnect to the running tasks.
On Fri, Jun 19, 2015 at 7:03 AM, Aditi Dixit <aditi96di...@gmail.com> wrote: > Hi, > I modified the test_framework.cpp file in examples with the help of Joris > so that I can check for framework reregistrations.(the patch is here : > https://gist.github.com/atidix/8d1de11f28744e934496 ). > > According to MesosSchedulerDriver, after I pass driver->stop(true), since > failover is True, the scheduler should reregister the framework right? But > what I see happening is that the Framework stops and then registers again. > Am I understanding something wrong or is this how it should go down? > > Regards, > Aditi Dixit > > PS: Output logs to verify my point > > akshay@charizardz:~/mesos/build$ ./src/test-framework --master= > 127.0.1.1:5050 > I0619 17:50:14.418045 29934 sched.cpp:157] Version: 0.23.0 > I0619 17:50:14.429234 29948 sched.cpp:254] New master detected at > master@127.0.1.1:5050 > I0619 17:50:14.430210 29948 sched.cpp:264] No credentials provided. > Attempting to register without authentication > I0619 17:50:14.436782 29954 sched.cpp:448] Framework registered with > 20150619-163754-16842879-5050-29356-0005 > Registered with id20150619-163754-16842879-5050-29356-0005! > Received offer 20150619-163754-16842879-5050-29356-O10 with mem(*):4892; > disk(*):692933; ports(*):[31000-32000]; cpus(*):4 > Launching task 0 using offer 20150619-163754-16842879-5050-29356-O10 > Launching task 1 using offer 20150619-163754-16842879-5050-29356-O10 > Launching task 2 using offer 20150619-163754-16842879-5050-29356-O10 > Launching task 3 using offer 20150619-163754-16842879-5050-29356-O10 > Task 0 is in state TASK_RUNNING > Task 1 is in state TASK_RUNNING > Task 0 is in state TASK_FINISHED > Task 2 is in state TASK_RUNNING > Task 1 is in state TASK_FINISHED > Task 3 is in state TASK_RUNNING > Task 2 is in state TASK_FINISHED > Task 3 is in state TASK_FINISHED > Received offer 20150619-163754-16842879-5050-29356-O11 with mem(*):4892; > disk(*):692933; ports(*):[31000-32000]; cpus(*):4 > Launching task 4 using offer 20150619-163754-16842879-5050-29356-O11 > Task 4 is in state TASK_RUNNING > Task 4 is in state TASK_FINISHED > I0619 17:50:15.555902 29950 sched.cpp:1591] Asked to stop the driver > > > > *I0619 17:50:15.555987 29950 sched.cpp:831] Stopping framework > '20150619-163754-16842879-5050-29356-0005'I0619 17:50:15.556049 29934 > sched.cpp:1591] Asked to stop the driverI0619 17:50:15.562646 29934 > sched.cpp:157] Version: 0.23.0* > > > *I0619 17:50:15.563300 29948 sched.cpp:254] New master detected > at master@127.0.1.1:5050 <http://master@127.0.1.1:5050/>I0619 > 17:50:15.563480 29948 sched.cpp:264] No credentials provided. Attempting to > register without authenticationI0619 17:50:15.565598 29948 sched.cpp:448] > Framework registered with > 20150619-163754-16842879-5050-29356-0005Registered with > id20150619-163754-16842879-5050-29356-0005!* > Task 4 is in state TASK_FINISHED > Received offer 20150619-163754-16842879-5050-29356-O12 with mem(*):4892; > disk(*):692933; ports(*):[31000-32000]; cpus(*):4 > Launching task 0 using offer 20150619-163754-16842879-5050-29356-O12 > Launching task 1 using offer 20150619-163754-16842879-5050-29356-O12 > Launching task 2 using offer 20150619-163754-16842879-5050-29356-O12 > Launching task 3 using offer 20150619-163754-16842879-5050-29356-O12 > Task 0 is in state TASK_RUNNING > Task 1 is in state TASK_RUNNING > Task 2 is in state TASK_RUNNING > Task 3 is in state TASK_RUNNING > Task 0 is in state TASK_FINISHED > Task 1 is in state TASK_FINISHED > Task 2 is in state TASK_FINISHED > Task 3 is in state TASK_FINISHED > I0619 17:50:16.592545 29954 sched.cpp:1591] Asked to stop the driver > I0619 17:50:16.592618 29954 sched.cpp:831] Stopping framework > '20150619-163754-16842879-5050-29356-0005' > I0619 17:50:16.592664 29934 sched.cpp:1591] Asked to stop the driver >
