{"action":"opened","issue":{"url":"https://api.github.com/repos/WallarooLabs/wallaroo/issues/2517","repository_url":"https://api.github.com/repos/WallarooLabs/wallaroo","labels_url":"https://api.github.com/repos/WallarooLabs/wallaroo/issues/2517/labels{/name}","comments_url":"https://api.github.com/repos/WallarooLabs/wallaroo/issues/2517/comments","events_url":"https://api.github.com/repos/WallarooLabs/wallaroo/issues/2517/events","html_url":"https://github.com/WallarooLabs/wallaroo/issues/2517","id":367342088,"node_id":"MDU6SXNzdWUzNjczNDIwODg=","number":2517,"title":"to_parallel following a state computation does not distribute work to all workers","user":{"login":"pzel","id":344774,"node_id":"MDQ6VXNlcjM0NDc3NA==","avatar_url":"https://avatars0.githubusercontent.com/u/344774?v=4","gravatar_id":"","url":"https://api.github.com/users/pzel","html_url":"https://github.com/pzel","followers_url":"https://api.github.com/users/pzel/followers","following_url":"https://api.github.com/users/pzel/following{/other_user}","gists_url":"https://api.github.com/users/pzel/gists{/gist_id}","starred_url":"https://api.github.com/users/pzel/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/pzel/subscriptions","organizations_url":"https://api.github.com/users/pzel/orgs","repos_url":"https://api.github.com/users/pzel/repos","events_url":"https://api.github.com/users/pzel/events{/privacy}","received_events_url":"https://api.github.com/users/pzel/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-10-05T19:38:52Z","updated_at":"2018-10-05T19:38:52Z","closed_at":null,"author_association":"MEMBER","body":"### Is this a bug, feature request, or feedback?\r\nThis is a bug.\r\n\r\n### What is the current behavior?\r\n\r\nIn a cluster of N workers that have a parallel stateless computation which follows a stateful computation in the logical graph, *not all N* workers actually receive work to process.\r\n\r\nSee [this branch](https://github.com/WallarooLabs/wallaroo/tree/state-to-parallel-fairness) for a demonstration.\r\n\r\n```\r\ncd examples/python/parallel-classifier\r\nmake parallel_classifier_py_test\r\n```\r\n\r\n### What is the expected behavior?\r\n\r\nIn the example above, where each worker's output is it's os-level PID, I expect the number of unique PIDs in the result log to be equal to the number of workers in the cluster (if there's enough work for them, of course).\r\n\r\n### What OS and version of Wallaroo are you using? If you have a stacktrace and/or steps to reproduce the issue, that also helps a lot.\r\n\r\nmaster\r\n"}}
{"actor":{"display_login":"pzel"}}