{"action":"created","issue":{"url":"https://api.github.com/repos/apache/spark/issues/13259","repository_url":"https://api.github.com/repos/apache/spark","labels_url":"https://api.github.com/repos/apache/spark/issues/13259/labels{/name}","comments_url":"https://api.github.com/repos/apache/spark/issues/13259/comments","events_url":"https://api.github.com/repos/apache/spark/issues/13259/events","html_url":"https://github.com/apache/spark/pull/13259","id":156216440,"number":13259,"title":"[SPARK-15480][UI][Streaming]show missed InputInfo in streaming UI","user":{"login":"mwws","id":13216322,"avatar_url":"https://avatars.githubusercontent.com/u/13216322?v=3","gravatar_id":"","url":"https://api.github.com/users/mwws","html_url":"https://github.com/mwws","followers_url":"https://api.github.com/users/mwws/followers","following_url":"https://api.github.com/users/mwws/following{/other_user}","gists_url":"https://api.github.com/users/mwws/gists{/gist_id}","starred_url":"https://api.github.com/users/mwws/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mwws/subscriptions","organizations_url":"https://api.github.com/users/mwws/orgs","repos_url":"https://api.github.com/users/mwws/repos","events_url":"https://api.github.com/users/mwws/events{/privacy}","received_events_url":"https://api.github.com/users/mwws/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2016-05-23T07:32:17Z","updated_at":"2016-05-24T01:21:55Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/spark/pulls/13259","html_url":"https://github.com/apache/spark/pull/13259","diff_url":"https://github.com/apache/spark/pull/13259.diff","patch_url":"https://github.com/apache/spark/pull/13259.patch"},"body":"## What changes were proposed in this pull request?\r\nIt's a bug in Streaming UI. If BatchDuration is changed by window operation, InputInfo on time with no output ops will not be shown in streaming UI.\r\n\r\nHere is a simple example to reproduce:\r\n```scala\r\nval inputDStream = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc, kafkaParam, topic)\r\nval matchedDStream = inputDStream.window(batchInteval*2, batchInteval*2)\r\nmatchedDStream.foreachRDD(rdd => {\r\n    val count = rdd.count()\r\n    println(s\"2 count number: ${count}\")\r\n})\r\n```\r\n\r\n## How was this patch tested?\r\nmanually tested\r\n\r\nScreenshot attached:\r\n![streamingui-bug](https://cloud.githubusercontent.com/assets/13216322/15463230/7ef5a4de-20fa-11e6-874b-b90b941cc9a4.png)\r\n\r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/apache/spark/issues/comments/221141661","html_url":"https://github.com/apache/spark/pull/13259#issuecomment-221141661","issue_url":"https://api.github.com/repos/apache/spark/issues/13259","id":221141661,"user":{"login":"mwws","id":13216322,"avatar_url":"https://avatars.githubusercontent.com/u/13216322?v=3","gravatar_id":"","url":"https://api.github.com/users/mwws","html_url":"https://github.com/mwws","followers_url":"https://api.github.com/users/mwws/followers","following_url":"https://api.github.com/users/mwws/following{/other_user}","gists_url":"https://api.github.com/users/mwws/gists{/gist_id}","starred_url":"https://api.github.com/users/mwws/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mwws/subscriptions","organizations_url":"https://api.github.com/users/mwws/orgs","repos_url":"https://api.github.com/users/mwws/repos","events_url":"https://api.github.com/users/mwws/events{/privacy}","received_events_url":"https://api.github.com/users/mwws/received_events","type":"User","site_admin":false},"created_at":"2016-05-24T01:21:54Z","updated_at":"2016-05-24T01:21:54Z","body":"@chenghao-intel @carsonwang "}}
{"actor":{"display_login":"mwws"}}