@Test
public void testGetRedirectAddressWithLocalAkkaPath() throws Exception {

	ActorGateway leaderGateway = new DummyActorGateway("akka://flink/user/foobar");
	Tuple2<ActorGateway, Integer> leader = new Tuple2<>(leaderGateway, 1235);
	String redirectingAddress =HandlerRedirectUtils.getRedirectAddress(localJobManagerAddress, leader);
	Assert.assertNull(redirectingAddress);
}