You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Hai Lu (JIRA)" <ji...@apache.org> on 2019/05/09 00:16:00 UTC

[jira] [Resolved] (SAMZA-2183) Print Jobmodel when job fails with incorrect container count

     [ https://issues.apache.org/jira/browse/SAMZA-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Hai Lu resolved SAMZA-2183.
---------------------------
    Resolution: Fixed

> Print Jobmodel when job fails with incorrect container count
> ------------------------------------------------------------
>
>                 Key: SAMZA-2183
>                 URL: https://issues.apache.org/jira/browse/SAMZA-2183
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: Hai Lu
>            Assignee: Hai Lu
>            Priority: Major
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> When a job fails to start due to the following exception, would be helpful to print the job model also 
>  
> Exception in thread "main" java.lang.IllegalArgumentException: Your container count (32) is larger than your task count (10). Can't have containers with nothing to do, so aborting. at org.apache.samza.container.grouper.task.GroupByContainerCount.validateTasks(GroupByContainerCount.java:212) at org.apache.samza.container.grouper.task.GroupByContainerCount.group(GroupByContainerCount.java:62) at org.apache.samza.container.grouper.task.TaskNameGrouper.group(TaskNameGrouper.java:56) at org.apache.samza.coordinator.JobModelManager$.readJobModel(JobModelManager.scala:208) at org.apache.samza.coordinator.JobModelManager$.getJobModelManager(JobModelManager.scala:97) at org.apache.samza.coordinator.JobModelManager$.apply(JobModelManager.scala:83) at org.apache.samza.coordinator.JobModelManager.apply(JobModelManager.scala) at org.apache.samza.clustermanager.ClusterBasedJobCoordinator.<init>(ClusterBasedJobCoordinator.java:177) at org.apache.samza.clustermanager.ClusterBasedJobCoordinator.main(ClusterBasedJobCoordinator.java:343)
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)