{"action":"created","issue":{"url":"https://api.github.com/repos/apache/flink/issues/1398","labels_url":"https://api.github.com/repos/apache/flink/issues/1398/labels{/name}","comments_url":"https://api.github.com/repos/apache/flink/issues/1398/comments","events_url":"https://api.github.com/repos/apache/flink/issues/1398/events","html_url":"https://github.com/apache/flink/pull/1398","id":118572705,"number":1398,"title":"[FLINK-2837][storm] various improvements for Storm compatibility","user":{"login":"mxm","id":837221,"avatar_url":"https://avatars.githubusercontent.com/u/837221?v=3","gravatar_id":"","url":"https://api.github.com/users/mxm","html_url":"https://github.com/mxm","followers_url":"https://api.github.com/users/mxm/followers","following_url":"https://api.github.com/users/mxm/following{/other_user}","gists_url":"https://api.github.com/users/mxm/gists{/gist_id}","starred_url":"https://api.github.com/users/mxm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mxm/subscriptions","organizations_url":"https://api.github.com/users/mxm/orgs","repos_url":"https://api.github.com/users/mxm/repos","events_url":"https://api.github.com/users/mxm/events{/privacy}","received_events_url":"https://api.github.com/users/mxm/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":3,"created_at":"2015-11-24T10:09:02Z","updated_at":"2015-12-01T14:21:47Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/flink/pulls/1398","html_url":"https://github.com/apache/flink/pull/1398","diff_url":"https://github.com/apache/flink/pull/1398.diff","patch_url":"https://github.com/apache/flink/pull/1398.patch"},"body":"This pull request contains various fixes. Most prominently, the parsing logic for Storm topologies has been changed to support multiple inputs. The API has been redone slightly. Two new examples have been added.\r\n\r\n- refactor to use Storm's topology builder\r\n\r\n- remove FlinkTopologyBuilder\r\n\r\n- instantiate context-based StreamExecutionEnvironment (local or remote)\r\n\r\n- remove Flink and Storm behavior replicating classes\r\n\r\n- modify FlinkTopology to parse Storm topology directly\r\n\r\n- replace StormTestBase with StreamingTestBase\r\n\r\n- let the FiniteFileSpout finish in corner cases\r\n\r\n- expose taskId, fix off by one task id\r\n\r\n- add print example\r\n\r\n- FlinkTopologyBuilder changes (check if all inputs are available before processing)\r\n\r\n- correct package typo\r\n\r\n- support getter methods on TupleWrapper\r\n\r\n- two input support\r\n\r\n- add join example\r\n\r\n- update docs\r\n\r\n- use Flink file system access"},"comment":{"url":"https://api.github.com/repos/apache/flink/issues/comments/160982088","html_url":"https://github.com/apache/flink/pull/1398#issuecomment-160982088","issue_url":"https://api.github.com/repos/apache/flink/issues/1398","id":160982088,"user":{"login":"mxm","id":837221,"avatar_url":"https://avatars.githubusercontent.com/u/837221?v=3","gravatar_id":"","url":"https://api.github.com/users/mxm","html_url":"https://github.com/mxm","followers_url":"https://api.github.com/users/mxm/followers","following_url":"https://api.github.com/users/mxm/following{/other_user}","gists_url":"https://api.github.com/users/mxm/gists{/gist_id}","starred_url":"https://api.github.com/users/mxm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mxm/subscriptions","organizations_url":"https://api.github.com/users/mxm/orgs","repos_url":"https://api.github.com/users/mxm/repos","events_url":"https://api.github.com/users/mxm/events{/privacy}","received_events_url":"https://api.github.com/users/mxm/received_events","type":"User","site_admin":false},"created_at":"2015-12-01T14:21:47Z","updated_at":"2015-12-01T14:21:47Z","body":"I've addressed your comments."}}