{"action":"created","issue":{"url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/issues/131","repository_url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler","labels_url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/issues/131/labels{/name}","comments_url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/issues/131/comments","events_url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/issues/131/events","html_url":"https://github.com/ScaleUnlimited/flink-crawler/issues/131","id":312375252,"number":131,"title":"ParseFunction is not displayed in the execution graph ","user":{"login":"vmagotra","id":64088,"avatar_url":"https://avatars2.githubusercontent.com/u/64088?v=4","gravatar_id":"","url":"https://api.github.com/users/vmagotra","html_url":"https://github.com/vmagotra","followers_url":"https://api.github.com/users/vmagotra/followers","following_url":"https://api.github.com/users/vmagotra/following{/other_user}","gists_url":"https://api.github.com/users/vmagotra/gists{/gist_id}","starred_url":"https://api.github.com/users/vmagotra/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/vmagotra/subscriptions","organizations_url":"https://api.github.com/users/vmagotra/orgs","repos_url":"https://api.github.com/users/vmagotra/repos","events_url":"https://api.github.com/users/vmagotra/events{/privacy}","received_events_url":"https://api.github.com/users/vmagotra/received_events","type":"User","site_admin":false},"labels":[{"id":432047947,"url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/labels/bug","name":"bug","color":"ee0701","default":true}],"state":"open","locked":false,"assignee":{"login":"vmagotra","id":64088,"avatar_url":"https://avatars2.githubusercontent.com/u/64088?v=4","gravatar_id":"","url":"https://api.github.com/users/vmagotra","html_url":"https://github.com/vmagotra","followers_url":"https://api.github.com/users/vmagotra/followers","following_url":"https://api.github.com/users/vmagotra/following{/other_user}","gists_url":"https://api.github.com/users/vmagotra/gists{/gist_id}","starred_url":"https://api.github.com/users/vmagotra/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/vmagotra/subscriptions","organizations_url":"https://api.github.com/users/vmagotra/orgs","repos_url":"https://api.github.com/users/vmagotra/repos","events_url":"https://api.github.com/users/vmagotra/events{/privacy}","received_events_url":"https://api.github.com/users/vmagotra/received_events","type":"User","site_admin":false},"assignees":[{"login":"vmagotra","id":64088,"avatar_url":"https://avatars2.githubusercontent.com/u/64088?v=4","gravatar_id":"","url":"https://api.github.com/users/vmagotra","html_url":"https://github.com/vmagotra","followers_url":"https://api.github.com/users/vmagotra/followers","following_url":"https://api.github.com/users/vmagotra/following{/other_user}","gists_url":"https://api.github.com/users/vmagotra/gists{/gist_id}","starred_url":"https://api.github.com/users/vmagotra/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/vmagotra/subscriptions","organizations_url":"https://api.github.com/users/vmagotra/orgs","repos_url":"https://api.github.com/users/vmagotra/repos","events_url":"https://api.github.com/users/vmagotra/events{/privacy}","received_events_url":"https://api.github.com/users/vmagotra/received_events","type":"User","site_admin":false}],"milestone":{"url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/milestones/1","html_url":"https://github.com/ScaleUnlimited/flink-crawler/milestone/1","labels_url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/milestones/1/labels","id":3076422,"number":1,"title":"Flink Forward 2018","description":"Code base I want to use for my talk at Flink Forward","creator":{"login":"kkrugler","id":66217,"avatar_url":"https://avatars3.githubusercontent.com/u/66217?v=4","gravatar_id":"","url":"https://api.github.com/users/kkrugler","html_url":"https://github.com/kkrugler","followers_url":"https://api.github.com/users/kkrugler/followers","following_url":"https://api.github.com/users/kkrugler/following{/other_user}","gists_url":"https://api.github.com/users/kkrugler/gists{/gist_id}","starred_url":"https://api.github.com/users/kkrugler/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kkrugler/subscriptions","organizations_url":"https://api.github.com/users/kkrugler/orgs","repos_url":"https://api.github.com/users/kkrugler/repos","events_url":"https://api.github.com/users/kkrugler/events{/privacy}","received_events_url":"https://api.github.com/users/kkrugler/received_events","type":"User","site_admin":false},"open_issues":6,"closed_issues":11,"state":"open","created_at":"2018-01-30T22:37:33Z","updated_at":"2018-04-09T02:54:29Z","due_on":"2018-04-01T07:00:00Z","closed_at":null},"comments":0,"created_at":"2018-04-09T02:54:29Z","updated_at":"2018-04-16T19:25:15Z","closed_at":null,"author_association":"CONTRIBUTOR","body":"From Ken -\r\n\r\n    I think this might be a bug...\r\n\r\n        // Save off parsed page content by passing it on to the provided content sink function.\r\n        parsedUrls\r\n            .name(\"Select fetched content\")\r\n            .addSink(_contentSink)\r\n            .name(\"ContentSink\")\r\n            .setParallelism(parseParallelism);\r\n\r\n        // Save off parsed page content text. So just extract the parsed content text piece of the Tuple3, and\r\n        // then pass it on to the provided content sink function (or just send it to the console).\r\n        DataStream<String> contentText = parsedUrls\r\n                .map(new MapFunction<ParsedUrl, String>() {\r\n\r\n    The issue is that calling parsedUrls.blah() returns a (potentially new) stream, which we’re not using to update the parsedUrls variable.\r\n\r\n    So then when we create the contentText stream, we’re using the old value for parsedUrls.\r\n"},"comment":{"url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/issues/comments/381720155","html_url":"https://github.com/ScaleUnlimited/flink-crawler/issues/131#issuecomment-381720155","issue_url":"https://api.github.com/repos/ScaleUnlimited/flink-crawler/issues/131","id":381720155,"user":{"login":"kkrugler","id":66217,"avatar_url":"https://avatars3.githubusercontent.com/u/66217?v=4","gravatar_id":"","url":"https://api.github.com/users/kkrugler","html_url":"https://github.com/kkrugler","followers_url":"https://api.github.com/users/kkrugler/followers","following_url":"https://api.github.com/users/kkrugler/following{/other_user}","gists_url":"https://api.github.com/users/kkrugler/gists{/gist_id}","starred_url":"https://api.github.com/users/kkrugler/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kkrugler/subscriptions","organizations_url":"https://api.github.com/users/kkrugler/orgs","repos_url":"https://api.github.com/users/kkrugler/repos","events_url":"https://api.github.com/users/kkrugler/events{/privacy}","received_events_url":"https://api.github.com/users/kkrugler/received_events","type":"User","site_admin":false},"created_at":"2018-04-16T19:25:15Z","updated_at":"2018-04-16T19:25:15Z","author_association":"OWNER","body":"Hi @vmagotra - is this now resolved?"}}
{"actor":{"display_login":"kkrugler"}}