Hi Anuj, I have observed similar problem in the past. most probably the application master is unable to connect to kafka cluster. can you check if you are using correct version of kafka client, And your kafka cluster is accessible with configuration you have provided.
Regards, -Tushar. On Tue, Jul 12, 2016 at 11:00 AM, ANUJ THAKWANI <[email protected]> wrote: > Hi Ram, > > Attaching Application.java for your reference. > > Application fails after 7-8 seconds. > > > > On Tue, Jul 12, 2016 at 10:55 AM, Munagala Ramanath <[email protected]> > wrote: >> >> Anuj, >> >> Could you provide additional details such as: What does your DAG look like >> ? What operators (custom as well as from Malhar) >> are you using ? Does this exception happen immediately upon launch or >> after >> some time ? >> >> Ram >> >> On Mon, Jul 11, 2016 at 10:12 PM, ANUJ THAKWANI <[email protected]> >> wrote: >> >> > Hi, >> > >> > I have subscribed to the dev list. Let me know the way forward. >> > >> > I am a newbie in this project . >> > >> > On Tue, Jul 12, 2016 at 10:31 AM, Amol Kekre <[email protected]> >> > wrote: >> > >> > > >> > > 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) >> > >> >> > > >> > > >> > > >
