Anuj, You are not yet subscribed to dev list, and hence will have trouble posting to this forum. Please subscribe by clicking on "subscribe" on the dev list as listed on http://apex.apache.org/community.html.
OR you can send an email to [email protected] with a subject text. Thks Amol On Mon, Jul 11, 2016 at 9:39 PM, ANUJ THAKWANI <[email protected]> wrote: > Hi, > > I am getting below given exception while launching kafka Application. > Please let me know how to fix this. > > java.lang.IllegalStateException: Partitioner returns null or empty. > at > com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:605) > at > com.datatorrent.stram.plan.physical.PhysicalPlan.addLogicalOperator(PhysicalPlan.java:1497) > at > com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:344) > at > com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:362) > at > com.datatorrent.stram.StreamingContainerManager.getInstance(StreamingContainerManager.java:2979) > at > com.datatorrent.stram.StreamingAppMasterService.serviceInit(StreamingAppMasterService.java:550) > at > org.apache.hadoop.service.AbstractService.init(AbstractService.java:163) > at > com.datatorrent.stram.StreamingAppMaster.main(StreamingAppMaster.java:101) > 2016-07-11 22:24:48,250 ERROR > com.datatorrent.stram.StreamingAppMaster: Exiting Application Master > java.lang.IllegalStateException: Partitioner returns null or empty. > at > com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:605) > at > com.datatorrent.stram.plan.physical.PhysicalPlan.addLogicalOperator(PhysicalPlan.java:1497) > at > com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:344) > at > com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:362) > at > com.datatorrent.stram.StreamingContainerManager.getInstance(StreamingContainerManager.java:2979) > at > com.datatorrent.stram.StreamingAppMasterService.serviceInit(StreamingAppMasterService.java:550) > at > org.apache.hadoop.service.AbstractService.init(AbstractService.java:163) > at > com.datatorrent.stram.StreamingAppMaster.main(StreamingAppMaster.java:101) >
