Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-2275

Kinesis consumer Error

    XMLWordPrintableJSON

    Details

    • Type: Test
    • Status: Open
    • Priority: Blocker
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: hello-samza
    • Labels:
      None

      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]

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                atoomula Aditya Toomula
                Reporter:
                alokm alok malakar
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 40m
                  40m