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

CoordinatorStream - Errors in JobRunner

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Invalid
    • Affects Version/s: 0.10.0
    • Fix Version/s: None
    • Component/s: container
    • Labels:
      None

      Description

      When starting a job which I have migrated from 0.9.1 I'm getting an error in JobRunner. I will attach full log output and configs.

      [yarnmaster01] out: Exception in thread "main" org.apache.samza.SamzaException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
      [yarnmaster01] out: at org.apache.samza.coordinator.stream.CoordinatorStreamSystemProducer.send(CoordinatorStreamSystemProducer.java:115)
      [yarnmaster01] out: at org.apache.samza.coordinator.stream.CoordinatorStreamSystemProducer.writeConfig(CoordinatorStreamSystemProducer.java:132)
      [yarnmaster01] out: at org.apache.samza.job.JobRunner.run(JobRunner.scala:85)
      [yarnmaster01] out: at org.apache.samza.job.JobRunner$.main(JobRunner.scala:43)
      [yarnmaster01] out: at org.apache.samza.job.JobRunner.main(JobRunner.scala)
      [yarnmaster01] out: Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
      [yarnmaster01] out:

        Attachments

        1. t_key_grouper.properties
          3 kB
          Rick Mangi
        2. joboutput.txt
          22 kB
          Rick Mangi

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              rmangi Rick Mangi
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: