{"action":"created","issue":{"url":"https://api.github.com/repos/apache/spark/issues/6034","labels_url":"https://api.github.com/repos/apache/spark/issues/6034/labels{/name}","comments_url":"https://api.github.com/repos/apache/spark/issues/6034/comments","events_url":"https://api.github.com/repos/apache/spark/issues/6034/events","html_url":"https://github.com/apache/spark/pull/6034","id":74739771,"number":6034,"title":"[SPARK-7501] [Streaming] DAG visualization: show DStream operations","user":{"login":"andrewor14","id":2133137,"avatar_url":"https://avatars.githubusercontent.com/u/2133137?v=3","gravatar_id":"","url":"https://api.github.com/users/andrewor14","html_url":"https://github.com/andrewor14","followers_url":"https://api.github.com/users/andrewor14/followers","following_url":"https://api.github.com/users/andrewor14/following{/other_user}","gists_url":"https://api.github.com/users/andrewor14/gists{/gist_id}","starred_url":"https://api.github.com/users/andrewor14/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/andrewor14/subscriptions","organizations_url":"https://api.github.com/users/andrewor14/orgs","repos_url":"https://api.github.com/users/andrewor14/repos","events_url":"https://api.github.com/users/andrewor14/events{/privacy}","received_events_url":"https://api.github.com/users/andrewor14/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":136,"created_at":"2015-05-09T19:22:06Z","updated_at":"2015-05-17T10:28:36Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/spark/pulls/6034","html_url":"https://github.com/apache/spark/pull/6034","diff_url":"https://github.com/apache/spark/pull/6034.diff","patch_url":"https://github.com/apache/spark/pull/6034.patch"},"body":"This is similar to #5999, but for streaming. Roughly 200 lines are tests.\r\n\r\nOne thing to note here is that we already do some kind of scoping thing for call sites, so this patch adds the new RDD operation scoping logic in the same place. Also, this patch adds a `try finally` block to set the relevant variables in a safer way.\r\n\r\n@tdas @zsxwing\r\n\r\n------------------------\r\n**Before**\r\n<img src=\"https://cloud.githubusercontent.com/assets/2133137/7625996/d88211b8-f9b4-11e4-90b9-e11baa52d6d7.png\" width=\"450px\"/>\r\n\r\n--------------------------\r\n**After**\r\n<img src=\"https://cloud.githubusercontent.com/assets/2133137/7625997/e0878f8c-f9b4-11e4-8df3-7dd611b13c87.png\" width=\"650px\"/>"},"comment":{"url":"https://api.github.com/repos/apache/spark/issues/comments/102780133","html_url":"https://github.com/apache/spark/pull/6034#issuecomment-102780133","issue_url":"https://api.github.com/repos/apache/spark/issues/6034","id":102780133,"user":{"login":"AmplabJenkins","id":4031291,"avatar_url":"https://avatars.githubusercontent.com/u/4031291?v=3","gravatar_id":"","url":"https://api.github.com/users/AmplabJenkins","html_url":"https://github.com/AmplabJenkins","followers_url":"https://api.github.com/users/AmplabJenkins/followers","following_url":"https://api.github.com/users/AmplabJenkins/following{/other_user}","gists_url":"https://api.github.com/users/AmplabJenkins/gists{/gist_id}","starred_url":"https://api.github.com/users/AmplabJenkins/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/AmplabJenkins/subscriptions","organizations_url":"https://api.github.com/users/AmplabJenkins/orgs","repos_url":"https://api.github.com/users/AmplabJenkins/repos","events_url":"https://api.github.com/users/AmplabJenkins/events{/privacy}","received_events_url":"https://api.github.com/users/AmplabJenkins/received_events","type":"User","site_admin":false},"created_at":"2015-05-17T10:28:35Z","updated_at":"2015-05-17T10:28:35Z","body":"Merged build finished. Test PASSed."}}