[jira] [Assigned] (SAMZA-2275) Kinesis consumer Error

["Prateek Maheshwari (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Prateek Maheshwari reassigned SAMZA-2275:
-----------------------------------------

    Assignee: Aditya

> Kinesis consumer Error 
> -----------------------
>
>                 Key: SAMZA-2275
>                 URL: https://issues.apache.org/jira/browse/SAMZA-2275
>             Project: Samza
>          Issue Type: Test
>          Components: hello-samza
>            Reporter: alok malakar
>            Assignee: Aditya
>            Priority: Blocker
>
>  
> I tired running  samza job to consume from Kinesis stream. The job runs however ends up with the Finalstatus = Failed, State= Finished.  
> While inspecting the stdout, I found below error, 
>  
> [main] BasicProfileConfigLoader [WARN] Your profile name includes a 'profile ' prefix. This is considered part of the profile name in the Java SDK, so you will need to include this prefix in your profile name when you reference this profile from your Java code.
> JMX Server: JmxServer registry port=46359 server port=42978 url=service:jmx:rmi://ip-172-31-84-253:42978/jndi/rmi://ip-172-31-84-253:46359/jmxrmi
> 07:16:56.357 [main] ERROR org.apache.samza.container.SamzaContainer - Caught exception/error while initializing container.
> java.lang.IllegalArgumentException: Ssp SystemStreamPartition [kinesis, kinesis-autoscaling-MyKinesisStream-9B3ECMRQ3TOU, 2] is already in free pool.
>  at org.apache.commons.lang.Validate.isTrue(Validate.java:136) ~[commons-lang-2.6.jar:2.6]



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)