{"action":"created","issue":{"url":"https://api.github.com/repos/apache/incubator-beam/issues/1408","repository_url":"https://api.github.com/repos/apache/incubator-beam","labels_url":"https://api.github.com/repos/apache/incubator-beam/issues/1408/labels{/name}","comments_url":"https://api.github.com/repos/apache/incubator-beam/issues/1408/comments","events_url":"https://api.github.com/repos/apache/incubator-beam/issues/1408/events","html_url":"https://github.com/apache/incubator-beam/pull/1408","id":190912269,"number":1408,"title":"[BEAM-25] Temporarily reject stateful ParDo in FlinkRunner (until support is added)","user":{"login":"kennknowles","id":575353,"avatar_url":"https://avatars.githubusercontent.com/u/575353?v=3","gravatar_id":"","url":"https://api.github.com/users/kennknowles","html_url":"https://github.com/kennknowles","followers_url":"https://api.github.com/users/kennknowles/followers","following_url":"https://api.github.com/users/kennknowles/following{/other_user}","gists_url":"https://api.github.com/users/kennknowles/gists{/gist_id}","starred_url":"https://api.github.com/users/kennknowles/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kennknowles/subscriptions","organizations_url":"https://api.github.com/users/kennknowles/orgs","repos_url":"https://api.github.com/users/kennknowles/repos","events_url":"https://api.github.com/users/kennknowles/events{/privacy}","received_events_url":"https://api.github.com/users/kennknowles/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-11-22T05:40:37Z","updated_at":"2016-11-22T10:53:04Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/incubator-beam/pulls/1408","html_url":"https://github.com/apache/incubator-beam/pull/1408","diff_url":"https://github.com/apache/incubator-beam/pull/1408.diff","patch_url":"https://github.com/apache/incubator-beam/pull/1408.patch"},"body":"Be sure to do all of the following to help us incorporate your contribution\r\nquickly and easily:\r\n\r\n - [x] Make sure the PR title is formatted like:\r\n   `[BEAM-<Jira issue #>] Description of pull request`\r\n - [x] Make sure tests pass via `mvn clean verify`. (Even better, enable\r\n       Travis-CI on your fork and ensure the whole test matrix passes).\r\n - [x] Replace `<Jira issue #>` in the title with the actual Jira issue\r\n       number, if there is one.\r\n - [x] If this contribution is large, please file an Apache\r\n       [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.txt).\r\n\r\n---\r\n\r\nR: @aljoscha or @mxm \r\n\r\nAt present, the user-facing API for stateful `DoFn` is in the codebase but prevented from use. It is `ParDo.of(...)` that rejects stateful `DoFn`. In #1399 I am removing this rejection, so I need to add it to all runners until they support the API.\r\n\r\nI have also added a JUnit category so runners can exclude this from their `RunnableOnService` test suites."},"comment":{"url":"https://api.github.com/repos/apache/incubator-beam/issues/comments/262209403","html_url":"https://github.com/apache/incubator-beam/pull/1408#issuecomment-262209403","issue_url":"https://api.github.com/repos/apache/incubator-beam/issues/1408","id":262209403,"user":{"login":"aljoscha","id":68551,"avatar_url":"https://avatars.githubusercontent.com/u/68551?v=3","gravatar_id":"","url":"https://api.github.com/users/aljoscha","html_url":"https://github.com/aljoscha","followers_url":"https://api.github.com/users/aljoscha/followers","following_url":"https://api.github.com/users/aljoscha/following{/other_user}","gists_url":"https://api.github.com/users/aljoscha/gists{/gist_id}","starred_url":"https://api.github.com/users/aljoscha/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/aljoscha/subscriptions","organizations_url":"https://api.github.com/users/aljoscha/orgs","repos_url":"https://api.github.com/users/aljoscha/repos","events_url":"https://api.github.com/users/aljoscha/events{/privacy}","received_events_url":"https://api.github.com/users/aljoscha/received_events","type":"User","site_admin":false},"created_at":"2016-11-22T10:53:04Z","updated_at":"2016-11-22T10:53:04Z","body":"LGTM!\r\n\r\nI postponed working on the Flink support because I'm waiting for the next Flink release where I exposed APIs for state and timers that I could use in the Flink runner. I might have to do it the hard way, though, so that we have something that works."}}
{"actor":{"display_login":"aljoscha"}}