[SAMZA-2275] Kinesis consumer Error

• Type: Test
• Status: Open
• Priority: Blocker
• Resolution: Unresolved
• Component/s: hello-samza
• Assignee: Aditya Toomula
• Reporter: alok malakar
• Created: 18/Jul/19 07:30
• Updated: 31/Jan/20 18:42

Description

 

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]

Issue Links

• links to: GitHub Pull Request #1258