@Test
public void testSelectChannelsLength() {

	sd1.setInstance(streamRecord1);
	assertEquals(1, keyGroupPartitioner.selectChannels(sd1, 1).length);
	assertEquals(1, keyGroupPartitioner.selectChannels(sd1, 2).length);
	assertEquals(1, keyGroupPartitioner.selectChannels(sd1, 1024).length);
}