[
https://issues.apache.org/jira/browse/APEXCORE-489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anuj closed APEXCORE-489.
-------------------------
Resolution: Fixed
> Getting exception while launching kafka application
> ---------------------------------------------------
>
> Key: APEXCORE-489
> URL: https://issues.apache.org/jira/browse/APEXCORE-489
> Project: Apache Apex Core
> Issue Type: Question
> Reporter: Anuj
>
> Getting below given exception while launching kafka application.
> 2016-07-12 10:33:02,243 INFO com.datatorrent.stram.StreamingAppMaster:
> Initializing Application Master.
> 2016-07-12 10:33:02,263 INFO com.datatorrent.stram.StreamingAppMasterService:
> Application master, appId=158, clustertimestamp=1465548058955, attemptId=1
> 2016-07-12 10:33:03,779 INFO
> com.datatorrent.contrib.kafka.AbstractKafkaInputOperator: [ONE_TO_ONE]:
> Initializing partition(s)
> 2016-07-12 10:33:03,781 INFO org.apache.hadoop.service.AbstractService:
> Service com.datatorrent.stram.StreamingAppMasterService failed in state
> INITED; cause: java.lang.IllegalStateException: Partitioner returns null or
> empty.
> 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-12 10:33:03,784 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)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
