{"action":"created","comment":{"url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/comments/34002916","id":34002916,"diff_hunk":"@@ -54,7 +54,7 @@ trait TaskScheduler {\n    * @param executorId which executorId this resource belongs to.\n    * @return\n    */\n-  def resourceAllocated(workerId : Int, executorId: Int) : Option[TaskLaunchData]\n+  def resourceAllocated(workerId : Int, executorId: Int, resource: Resource) : List[TaskId]","path":"streaming/src/main/scala/org/apache/gearpump/streaming/appmaster/TaskSchedulerImpl.scala","position":27,"original_position":27,"commit_id":"abde784c965777a5cf44726a1ccc99119b8c78f0","original_commit_id":"abde784c965777a5cf44726a1ccc99119b8c78f0","user":{"login":"whjiang","id":5162753,"avatar_url":"https://avatars.githubusercontent.com/u/5162753?v=3","gravatar_id":"","url":"https://api.github.com/users/whjiang","html_url":"https://github.com/whjiang","followers_url":"https://api.github.com/users/whjiang/followers","following_url":"https://api.github.com/users/whjiang/following{/other_user}","gists_url":"https://api.github.com/users/whjiang/gists{/gist_id}","starred_url":"https://api.github.com/users/whjiang/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/whjiang/subscriptions","organizations_url":"https://api.github.com/users/whjiang/orgs","repos_url":"https://api.github.com/users/whjiang/repos","events_url":"https://api.github.com/users/whjiang/events{/privacy}","received_events_url":"https://api.github.com/users/whjiang/received_events","type":"User","site_admin":false},"body":"Better rename this function as ```allocateResource``` to better reflect what it want s to do. ","created_at":"2015-07-07T02:12:29Z","updated_at":"2015-07-07T02:12:29Z","html_url":"https://github.com/intel-hadoop/gearpump/pull/1091#discussion_r34002916","pull_request_url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091","_links":{"self":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/comments/34002916"},"html":{"href":"https://github.com/intel-hadoop/gearpump/pull/1091#discussion_r34002916"},"pull_request":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091"}}},"pull_request":{"url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091","id":38977408,"html_url":"https://github.com/intel-hadoop/gearpump/pull/1091","diff_url":"https://github.com/intel-hadoop/gearpump/pull/1091.diff","patch_url":"https://github.com/intel-hadoop/gearpump/pull/1091.patch","issue_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/1091","number":1091,"state":"open","locked":false,"title":"#101 dynamic dag","user":{"login":"clockfly","id":2595532,"avatar_url":"https://avatars.githubusercontent.com/u/2595532?v=3","gravatar_id":"","url":"https://api.github.com/users/clockfly","html_url":"https://github.com/clockfly","followers_url":"https://api.github.com/users/clockfly/followers","following_url":"https://api.github.com/users/clockfly/following{/other_user}","gists_url":"https://api.github.com/users/clockfly/gists{/gist_id}","starred_url":"https://api.github.com/users/clockfly/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/clockfly/subscriptions","organizations_url":"https://api.github.com/users/clockfly/orgs","repos_url":"https://api.github.com/users/clockfly/repos","events_url":"https://api.github.com/users/clockfly/events{/privacy}","received_events_url":"https://api.github.com/users/clockfly/received_events","type":"User","site_admin":false},"body":"Dynamic DAG is a feature which allows you to change the runtime DAG in the fly. Without disrupting the application.\r\n\r\nThe goal of dynamic dag is:\r\n1. smooth upgrade. No message loss.\r\n2. In the transition process of dynamic DAG, we can remain the \"exactly once\" message processing feature.\r\n3. Automatically fall-back to old DAG, when upgrading failed.\r\n\r\nWith dynamic DAG, we can:\r\n1. Update only certain part of the DAG, without disrupting service.\r\n2. Change the task parallism dynamically with no message loss.\r\n3. Change configuration of task dynamically.\r\n4. Add new data source to exsting runtime DAG.\r\n5. Add new sink to existing DAG, like writing a extra copy to HDFS.\r\n6. Create temporary processors to existing DAG, to inspect the application status.\r\n","created_at":"2015-07-01T12:37:44Z","updated_at":"2015-07-07T02:12:29Z","closed_at":null,"merged_at":null,"merge_commit_sha":"843f404f6737cbb0e7e97903f582b1ba09059def","assignee":null,"milestone":null,"commits_url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091/commits","review_comments_url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091/comments","review_comment_url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/comments{/number}","comments_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/1091/comments","statuses_url":"https://api.github.com/repos/intel-hadoop/gearpump/statuses/abde784c965777a5cf44726a1ccc99119b8c78f0","head":{"label":"clockfly:dyn_6","ref":"dyn_6","sha":"abde784c965777a5cf44726a1ccc99119b8c78f0","user":{"login":"clockfly","id":2595532,"avatar_url":"https://avatars.githubusercontent.com/u/2595532?v=3","gravatar_id":"","url":"https://api.github.com/users/clockfly","html_url":"https://github.com/clockfly","followers_url":"https://api.github.com/users/clockfly/followers","following_url":"https://api.github.com/users/clockfly/following{/other_user}","gists_url":"https://api.github.com/users/clockfly/gists{/gist_id}","starred_url":"https://api.github.com/users/clockfly/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/clockfly/subscriptions","organizations_url":"https://api.github.com/users/clockfly/orgs","repos_url":"https://api.github.com/users/clockfly/repos","events_url":"https://api.github.com/users/clockfly/events{/privacy}","received_events_url":"https://api.github.com/users/clockfly/received_events","type":"User","site_admin":false},"repo":{"id":23338500,"name":"gearpump","full_name":"clockfly/gearpump","owner":{"login":"clockfly","id":2595532,"avatar_url":"https://avatars.githubusercontent.com/u/2595532?v=3","gravatar_id":"","url":"https://api.github.com/users/clockfly","html_url":"https://github.com/clockfly","followers_url":"https://api.github.com/users/clockfly/followers","following_url":"https://api.github.com/users/clockfly/following{/other_user}","gists_url":"https://api.github.com/users/clockfly/gists{/gist_id}","starred_url":"https://api.github.com/users/clockfly/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/clockfly/subscriptions","organizations_url":"https://api.github.com/users/clockfly/orgs","repos_url":"https://api.github.com/users/clockfly/repos","events_url":"https://api.github.com/users/clockfly/events{/privacy}","received_events_url":"https://api.github.com/users/clockfly/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/clockfly/gearpump","description":"gearpump","fork":true,"url":"https://api.github.com/repos/clockfly/gearpump","forks_url":"https://api.github.com/repos/clockfly/gearpump/forks","keys_url":"https://api.github.com/repos/clockfly/gearpump/keys{/key_id}","collaborators_url":"https://api.github.com/repos/clockfly/gearpump/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/clockfly/gearpump/teams","hooks_url":"https://api.github.com/repos/clockfly/gearpump/hooks","issue_events_url":"https://api.github.com/repos/clockfly/gearpump/issues/events{/number}","events_url":"https://api.github.com/repos/clockfly/gearpump/events","assignees_url":"https://api.github.com/repos/clockfly/gearpump/assignees{/user}","branches_url":"https://api.github.com/repos/clockfly/gearpump/branches{/branch}","tags_url":"https://api.github.com/repos/clockfly/gearpump/tags","blobs_url":"https://api.github.com/repos/clockfly/gearpump/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/clockfly/gearpump/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/clockfly/gearpump/git/refs{/sha}","trees_url":"https://api.github.com/repos/clockfly/gearpump/git/trees{/sha}","statuses_url":"https://api.github.com/repos/clockfly/gearpump/statuses/{sha}","languages_url":"https://api.github.com/repos/clockfly/gearpump/languages","stargazers_url":"https://api.github.com/repos/clockfly/gearpump/stargazers","contributors_url":"https://api.github.com/repos/clockfly/gearpump/contributors","subscribers_url":"https://api.github.com/repos/clockfly/gearpump/subscribers","subscription_url":"https://api.github.com/repos/clockfly/gearpump/subscription","commits_url":"https://api.github.com/repos/clockfly/gearpump/commits{/sha}","git_commits_url":"https://api.github.com/repos/clockfly/gearpump/git/commits{/sha}","comments_url":"https://api.github.com/repos/clockfly/gearpump/comments{/number}","issue_comment_url":"https://api.github.com/repos/clockfly/gearpump/issues/comments{/number}","contents_url":"https://api.github.com/repos/clockfly/gearpump/contents/{+path}","compare_url":"https://api.github.com/repos/clockfly/gearpump/compare/{base}...{head}","merges_url":"https://api.github.com/repos/clockfly/gearpump/merges","archive_url":"https://api.github.com/repos/clockfly/gearpump/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/clockfly/gearpump/downloads","issues_url":"https://api.github.com/repos/clockfly/gearpump/issues{/number}","pulls_url":"https://api.github.com/repos/clockfly/gearpump/pulls{/number}","milestones_url":"https://api.github.com/repos/clockfly/gearpump/milestones{/number}","notifications_url":"https://api.github.com/repos/clockfly/gearpump/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/clockfly/gearpump/labels{/name}","releases_url":"https://api.github.com/repos/clockfly/gearpump/releases{/id}","created_at":"2014-08-26T04:17:07Z","updated_at":"2015-04-28T05:17:53Z","pushed_at":"2015-07-06T12:23:08Z","git_url":"git://github.com/clockfly/gearpump.git","ssh_url":"git@github.com:clockfly/gearpump.git","clone_url":"https://github.com/clockfly/gearpump.git","svn_url":"https://github.com/clockfly/gearpump","homepage":"","size":10213,"stargazers_count":1,"watchers_count":1,"language":"Scala","has_issues":false,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":1,"mirror_url":null,"open_issues_count":0,"forks":1,"open_issues":0,"watchers":1,"default_branch":"master"}},"base":{"label":"intel-hadoop:master","ref":"master","sha":"6939406aa02cd1dd75d87bb755cf78e9ea994750","user":{"login":"intel-hadoop","id":1839373,"avatar_url":"https://avatars.githubusercontent.com/u/1839373?v=3","gravatar_id":"","url":"https://api.github.com/users/intel-hadoop","html_url":"https://github.com/intel-hadoop","followers_url":"https://api.github.com/users/intel-hadoop/followers","following_url":"https://api.github.com/users/intel-hadoop/following{/other_user}","gists_url":"https://api.github.com/users/intel-hadoop/gists{/gist_id}","starred_url":"https://api.github.com/users/intel-hadoop/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/intel-hadoop/subscriptions","organizations_url":"https://api.github.com/users/intel-hadoop/orgs","repos_url":"https://api.github.com/users/intel-hadoop/repos","events_url":"https://api.github.com/users/intel-hadoop/events{/privacy}","received_events_url":"https://api.github.com/users/intel-hadoop/received_events","type":"Organization","site_admin":false},"repo":{"id":22139167,"name":"gearpump","full_name":"intel-hadoop/gearpump","owner":{"login":"intel-hadoop","id":1839373,"avatar_url":"https://avatars.githubusercontent.com/u/1839373?v=3","gravatar_id":"","url":"https://api.github.com/users/intel-hadoop","html_url":"https://github.com/intel-hadoop","followers_url":"https://api.github.com/users/intel-hadoop/followers","following_url":"https://api.github.com/users/intel-hadoop/following{/other_user}","gists_url":"https://api.github.com/users/intel-hadoop/gists{/gist_id}","starred_url":"https://api.github.com/users/intel-hadoop/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/intel-hadoop/subscriptions","organizations_url":"https://api.github.com/users/intel-hadoop/orgs","repos_url":"https://api.github.com/users/intel-hadoop/repos","events_url":"https://api.github.com/users/intel-hadoop/events{/privacy}","received_events_url":"https://api.github.com/users/intel-hadoop/received_events","type":"Organization","site_admin":false},"private":false,"html_url":"https://github.com/intel-hadoop/gearpump","description":"Lightweight real-time big data streaming engine","fork":false,"url":"https://api.github.com/repos/intel-hadoop/gearpump","forks_url":"https://api.github.com/repos/intel-hadoop/gearpump/forks","keys_url":"https://api.github.com/repos/intel-hadoop/gearpump/keys{/key_id}","collaborators_url":"https://api.github.com/repos/intel-hadoop/gearpump/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/intel-hadoop/gearpump/teams","hooks_url":"https://api.github.com/repos/intel-hadoop/gearpump/hooks","issue_events_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/events{/number}","events_url":"https://api.github.com/repos/intel-hadoop/gearpump/events","assignees_url":"https://api.github.com/repos/intel-hadoop/gearpump/assignees{/user}","branches_url":"https://api.github.com/repos/intel-hadoop/gearpump/branches{/branch}","tags_url":"https://api.github.com/repos/intel-hadoop/gearpump/tags","blobs_url":"https://api.github.com/repos/intel-hadoop/gearpump/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/intel-hadoop/gearpump/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/intel-hadoop/gearpump/git/refs{/sha}","trees_url":"https://api.github.com/repos/intel-hadoop/gearpump/git/trees{/sha}","statuses_url":"https://api.github.com/repos/intel-hadoop/gearpump/statuses/{sha}","languages_url":"https://api.github.com/repos/intel-hadoop/gearpump/languages","stargazers_url":"https://api.github.com/repos/intel-hadoop/gearpump/stargazers","contributors_url":"https://api.github.com/repos/intel-hadoop/gearpump/contributors","subscribers_url":"https://api.github.com/repos/intel-hadoop/gearpump/subscribers","subscription_url":"https://api.github.com/repos/intel-hadoop/gearpump/subscription","commits_url":"https://api.github.com/repos/intel-hadoop/gearpump/commits{/sha}","git_commits_url":"https://api.github.com/repos/intel-hadoop/gearpump/git/commits{/sha}","comments_url":"https://api.github.com/repos/intel-hadoop/gearpump/comments{/number}","issue_comment_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/comments{/number}","contents_url":"https://api.github.com/repos/intel-hadoop/gearpump/contents/{+path}","compare_url":"https://api.github.com/repos/intel-hadoop/gearpump/compare/{base}...{head}","merges_url":"https://api.github.com/repos/intel-hadoop/gearpump/merges","archive_url":"https://api.github.com/repos/intel-hadoop/gearpump/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/intel-hadoop/gearpump/downloads","issues_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues{/number}","pulls_url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls{/number}","milestones_url":"https://api.github.com/repos/intel-hadoop/gearpump/milestones{/number}","notifications_url":"https://api.github.com/repos/intel-hadoop/gearpump/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/intel-hadoop/gearpump/labels{/name}","releases_url":"https://api.github.com/repos/intel-hadoop/gearpump/releases{/id}","created_at":"2014-07-23T08:55:26Z","updated_at":"2015-07-06T06:08:56Z","pushed_at":"2015-07-06T12:23:09Z","git_url":"git://github.com/intel-hadoop/gearpump.git","ssh_url":"git@github.com:intel-hadoop/gearpump.git","clone_url":"https://github.com/intel-hadoop/gearpump.git","svn_url":"https://github.com/intel-hadoop/gearpump","homepage":"http://gearpump.io","size":13907,"stargazers_count":302,"watchers_count":302,"language":"Scala","has_issues":true,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":62,"mirror_url":null,"open_issues_count":117,"forks":62,"open_issues":117,"watchers":302,"default_branch":"master"}},"_links":{"self":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091"},"html":{"href":"https://github.com/intel-hadoop/gearpump/pull/1091"},"issue":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/issues/1091"},"comments":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/issues/1091/comments"},"review_comments":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091/comments"},"review_comment":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/comments{/number}"},"commits":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/1091/commits"},"statuses":{"href":"https://api.github.com/repos/intel-hadoop/gearpump/statuses/abde784c965777a5cf44726a1ccc99119b8c78f0"}}}}