apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anuj (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (APEXCORE-489) Getting exception while launching kafka application
Date Wed, 13 Jul 2016 15:48:20 GMT

     [ 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)

Mime
View raw message