[SAMZA-815] CoordinatorStream - Errors in JobRunner

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Invalid
• Affects Version/s: 0.10.0
• Component/s: container
• Assignee: Unassigned
• Reporter: Rick Mangi
• Created: 13/Nov/15 17:03
• Updated: 17/Nov/15 15:58
• Resolved: 17/Nov/15 15:58

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: