-
Type:
Bug
-
Status: Resolved
-
Priority:
Blocker
-
Resolution: Invalid
-
Affects Version/s: 0.10.0
-
Fix Version/s: None
-
Component/s: container
-
Labels:None
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: