@Test(expected = IllegalStateException.class)
public void testRetriggerWithoutPartitionRequest() throws Exception {

	Tuple2<Integer, Integer> backoff = new Tuple2<Integer, Integer>(500, 3000);
	PartitionRequestClient connClient = mock(PartitionRequestClient.class);
	SingleInputGate inputGate = mock(SingleInputGate.class);
	RemoteInputChannel ch = createRemoteInputChannel(inputGate, connClient, backoff);
	ch.retriggerSubpartitionRequest(0);
}