{"action":"created","issue":{"url":"https://api.github.com/repos/apache/beam/issues/7174","repository_url":"https://api.github.com/repos/apache/beam","labels_url":"https://api.github.com/repos/apache/beam/issues/7174/labels{/name}","comments_url":"https://api.github.com/repos/apache/beam/issues/7174/comments","events_url":"https://api.github.com/repos/apache/beam/issues/7174/events","html_url":"https://github.com/apache/beam/pull/7174","id":386360428,"node_id":"MDExOlB1bGxSZXF1ZXN0MjM1MTIzMjUw","number":7174,"title":"[BEAM-5978] Changing parallelism for wordcount to 1","user":{"login":"angoenka","id":38219,"node_id":"MDQ6VXNlcjM4MjE5","avatar_url":"https://avatars3.githubusercontent.com/u/38219?v=4","gravatar_id":"","url":"https://api.github.com/users/angoenka","html_url":"https://github.com/angoenka","followers_url":"https://api.github.com/users/angoenka/followers","following_url":"https://api.github.com/users/angoenka/following{/other_user}","gists_url":"https://api.github.com/users/angoenka/gists{/gist_id}","starred_url":"https://api.github.com/users/angoenka/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/angoenka/subscriptions","organizations_url":"https://api.github.com/users/angoenka/orgs","repos_url":"https://api.github.com/users/angoenka/repos","events_url":"https://api.github.com/users/angoenka/events{/privacy}","received_events_url":"https://api.github.com/users/angoenka/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":2,"created_at":"2018-11-30T21:40:45Z","updated_at":"2018-12-02T03:13:36Z","closed_at":null,"author_association":"CONTRIBUTOR","pull_request":{"url":"https://api.github.com/repos/apache/beam/pulls/7174","html_url":"https://github.com/apache/beam/pull/7174","diff_url":"https://github.com/apache/beam/pull/7174.diff","patch_url":"https://github.com/apache/beam/pull/7174.patch"},"body":"Local execution environment sets the parallelism of the pipeline same as the number of cores on the machine. In my case, its 12. As we have 12 threads in SDKHarness, we get a deadlock on my machine.\r\nRunning on a cluster does not have this issue as the default parallelism there is 1.\r\n------------------------\r\n\r\nFollow this checklist to help us incorporate your contribution quickly and easily:\r\n\r\n - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.\r\n - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).\r\n\r\nIt will help us expedite review of your Pull Request if you tag someone (e.g. `@username`) to look at it.\r\n\r\nPost-Commit Tests Status (on master branch)\r\n------------------------------------------------------------------------------------------------\r\n\r\nLang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark\r\n--- | --- | --- | --- | --- | --- | --- | ---\r\nGo | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/lastCompletedBuild/) | --- | --- | --- | --- | --- | ---\r\nJava | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/lastCompletedBuild/) [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark_Gradle/lastCompletedBuild/)\r\nPython | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Python_Verify/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Python_Verify/lastCompletedBuild/) | --- | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/) </br> [![Build Status](https://builds.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/) | --- | --- | ---\r\n\r\n\r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/apache/beam/issues/comments/443477432","html_url":"https://github.com/apache/beam/pull/7174#issuecomment-443477432","issue_url":"https://api.github.com/repos/apache/beam/issues/7174","id":443477432,"node_id":"MDEyOklzc3VlQ29tbWVudDQ0MzQ3NzQzMg==","user":{"login":"tweise","id":263695,"node_id":"MDQ6VXNlcjI2MzY5NQ==","avatar_url":"https://avatars1.githubusercontent.com/u/263695?v=4","gravatar_id":"","url":"https://api.github.com/users/tweise","html_url":"https://github.com/tweise","followers_url":"https://api.github.com/users/tweise/followers","following_url":"https://api.github.com/users/tweise/following{/other_user}","gists_url":"https://api.github.com/users/tweise/gists{/gist_id}","starred_url":"https://api.github.com/users/tweise/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/tweise/subscriptions","organizations_url":"https://api.github.com/users/tweise/orgs","repos_url":"https://api.github.com/users/tweise/repos","events_url":"https://api.github.com/users/tweise/events{/privacy}","received_events_url":"https://api.github.com/users/tweise/received_events","type":"User","site_admin":false},"created_at":"2018-12-02T03:13:36Z","updated_at":"2018-12-02T03:13:36Z","author_association":"CONTRIBUTOR","body":"We could also fold this change into https://github.com/apache/beam/pull/7180\r\n\r\nUnrelated to this change, note that currently wordcount doesn't work on macOS with the docker jobserver:\r\n```\r\n./gradlew :beam-sdks-python:portableWordCount\r\n...\r\nINFO:root:Using latest locally built Python SDK docker image.\r\ndocker: Error response from daemon: driver failed programming external connectivity on endpoint cranky_pasteur (f9b3843dada38679d655f258ca40af36b030b469f2abbd2277db199683018b53):  (iptables failed: iptables --wait -t nat -A DOCKER -p tcp -d 0/0 --dport 32817 -j DNAT --to-destination 172.17.0.2:0 ! -i docker0: iptables v1.6.2: Port `0' not valid\r\n\r\nTry `iptables -h' or 'iptables --help' for more information.\r\n (exit status 2)).\r\n```\r\n\r\n"}}
{"actor":{"display_login":"tweise"}}