[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647978#comment-16647978 ] Thomas Weise commented on BEAM-5713: It isn't consistent / deterministic. Subsequent runs of same

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647630#comment-16647630 ] Maximilian Michels commented on BEAM-5713: -- {quote} I added more tasks and they are all squeezed

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647169#comment-16647169 ] Thomas Weise commented on BEAM-5713: With parallelism 4, *almost* same

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646887#comment-16646887 ] Thomas Weise commented on BEAM-5713: I added more tasks and they are all squeezed into the same slots

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646847#comment-16646847 ] Thomas Weise commented on BEAM-5713: Just to confirm my observation: We have 16 task slots per TM. The

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646815#comment-16646815 ] Maximilian Michels commented on BEAM-5713: -- After testing this with native Flink jobs, looking

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646497#comment-16646497 ] Maximilian Michels commented on BEAM-5713: -- Putting the native source into a different

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646493#comment-16646493 ] Thomas Weise commented on BEAM-5713: That's something we should fix for the standard Impulse

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646479#comment-16646479 ] Maximilian Michels commented on BEAM-5713: -- Seems like this was largely by chance because your

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646345#comment-16646345 ] Maximilian Michels commented on BEAM-5713: -- !With RichParallelSourceFunction and parallelism

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646343#comment-16646343 ] Maximilian Michels commented on BEAM-5713: -- Actually, this is a FlinkRunner bug. The Impulse

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646325#comment-16646325 ] Maximilian Michels commented on BEAM-5713: -- This is a "feature". See

[jira] [Commented] (BEAM-5713) Flink portable runner schedules all tasks of streaming job on same task manager

[ https://issues.apache.org/jira/browse/BEAM-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645821#comment-16645821 ] Thomas Weise commented on BEAM-5713: Can be reproduced with branch: