diff --git a/lib/rob/schedulers/v1/pool/sink/sink.go b/lib/rob/schedulers/v1/pool/sink/sink.go
index d512ca0034704ab5de01715f1718f8fb022e5613..52b67bdb33dae6ab08345f713b757308a231081f 100644
--- a/lib/rob/schedulers/v1/pool/sink/sink.go
+++ b/lib/rob/schedulers/v1/pool/sink/sink.go
@@ -75,8 +75,15 @@ func (T *Sink) trySchedule(j job.Stalled) bool {
 		return false
 	}
 
-	stride := T.stride[j.Source]
-	if stride < T.floor {
+	stride, ok := T.stride[j.Source]
+	if !ok {
+		// set to max
+		stride = T.floor
+		if s, _, ok := T.scheduled.Max(); ok {
+			stride = s + 1
+		}
+		T.stride[j.Source] = stride
+	} else if stride < T.floor {
 		stride = T.floor
 		T.stride[j.Source] = stride
 	}
diff --git a/lib/rob/schedulers/v1/scheduler_test.go b/lib/rob/schedulers/v1/scheduler_test.go
index 5fe4d55ea9cf20910a7dca9caf3b2e26410a1a3e..da5f41a740d34d09b93b73c3f5e600b58aa4949d 100644
--- a/lib/rob/schedulers/v1/scheduler_test.go
+++ b/lib/rob/schedulers/v1/scheduler_test.go
@@ -79,6 +79,17 @@ func testSource(sched *Scheduler, id int, dur time.Duration, constraints rob.Con
 	}
 }
 
+func testStarver(sched *Scheduler, id int, dur time.Duration, constraints rob.Constraints) {
+	for {
+		source := sched.NewSource()
+		w := Work{
+			Sender:   id,
+			Duration: dur,
+		}
+		source.Do(constraints, w)
+	}
+}
+
 func similar(v0, v1 int, vn ...int) bool {
 	const margin = 0.05 // 5% margin of error
 
@@ -361,3 +372,32 @@ func TestScheduler_LateSink(t *testing.T) {
 
 	t.Log("share of 0:", t0)
 }
+
+func TestScheduler_Starve(t *testing.T) {
+	var table ShareTable
+	sched := NewScheduler()
+
+	testSink(sched, &table, 0)
+
+	go testStarver(sched, 1, 10*time.Millisecond, 0)
+	go testStarver(sched, 2, 10*time.Millisecond, 0)
+	go testSource(sched, 0, 10*time.Millisecond, 0)
+
+	time.Sleep(20 * time.Second)
+	t0 := table.Get(0)
+	t1 := table.Get(1)
+	t2 := table.Get(2)
+
+	/*
+		Expectations:
+		- 0 should not be starved
+	*/
+
+	t.Log("share of 0:", t0)
+	t.Log("share of 1:", t1)
+	t.Log("share of 2:", t2)
+
+	if !similar(t0, t1, t2) {
+		t.Error("expected all executions to be similar (is 0 starving?)")
+	}
+}