You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "alok malakar (JIRA)" <ji...@apache.org> on 2019/07/18 07:31:00 UTC

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

alok malakar created SAMZA-2275:
-----------------------------------

             Summary: 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


 

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)