{"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":27,"created_at":"2015-05-09T19:22:06Z","updated_at":"2015-05-14T04:22:11Z","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.\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/101904995","html_url":"https://github.com/apache/spark/pull/6034#issuecomment-101904995","issue_url":"https://api.github.com/repos/apache/spark/issues/6034","id":101904995,"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-14T04:22:11Z","updated_at":"2015-05-14T04:22:11Z","body":"Merged build finished. Test FAILed."}}