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)
