)]}'
{"sahara/plugins/cdh/cloudera_utils.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":217,"context_line":"        api \u003d self.get_api_client(instances[0].cluster)"},{"line_number":218,"context_line":"        poll_utils.plugin_option_poll("},{"line_number":219,"context_line":"            cluster, self._agents_connected, timeout_config,"},{"line_number":220,"context_line":"            _(\"Await Cloudera Agents\"), 5, {"},{"line_number":221,"context_line":"                \u0027instances\u0027: instances, \u0027api\u0027: api})"},{"line_number":222,"context_line":""},{"line_number":223,"context_line":"    def configure_instances(self, instances, cluster\u003dNone):"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_0916b7a7","line":220,"updated":"2015-03-17 15:27:59.000000000","message":"s/Agents/agents","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"}],"sahara/plugins/cdh/plugin_utils.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":269,"context_line":"            return False"},{"line_number":270,"context_line":""},{"line_number":271,"context_line":"    @cpo.event_wrapper("},{"line_number":272,"context_line":"        True, step\u003d_(\"Start Cloudera manager\"), param\u003d(\u0027cluster\u0027, 1))"},{"line_number":273,"context_line":"    def _start_cloudera_manager(self, cluster, timeout_config):"},{"line_number":274,"context_line":"        manager \u003d self.get_manager(cluster)"},{"line_number":275,"context_line":"        with manager.remote() as r:"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_a43232f0","line":272,"updated":"2015-03-17 15:27:59.000000000","message":"s/manager/Manager","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"}],"sahara/plugins/cdh/v5/cloudera_utils.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7152bbefa44a0e6b95d564d298c8e0880f0908d4","unresolved":false,"context_lines":[{"line_number":127,"context_line":"            cm_cluster.create_service(self.HBASE_SERVICE_NAME,"},{"line_number":128,"context_line":"                                      HBASE_SERVICE_TYPE)"},{"line_number":129,"context_line":""},{"line_number":130,"context_line":"    def is_agents_connected(self, cluster, instances, api):"},{"line_number":131,"context_line":"        hostnames \u003d [i.fqdn() for i in instances]"},{"line_number":132,"context_line":"        hostnames_to_manager \u003d [h.hostname for h in"},{"line_number":133,"context_line":"                                api.get_all_hosts(\u0027full\u0027)]"}],"source_content_type":"text/x-python","patch_set":2,"id":"ba7be1f8_15cd5631","line":130,"updated":"2015-03-04 00:33:27.000000000","message":"the title of this reads oddly, i think it should be \"agents_connected\" or possibly \"are_agents_connected\". my preference is the former.","commit_id":"32e8f73c881e8b60ae1bfa52f801eaf327e8711d"},{"author":{"_account_id":7535,"name":"Nikolay Starodubtsev","email":"starodubcevna@gmail.com","username":"Kezar"},"change_message_id":"c0493da36f4baf763a6cfe1e6b9e6146331a2cdc","unresolved":false,"context_lines":[{"line_number":129,"context_line":"        return True"},{"line_number":130,"context_line":""},{"line_number":131,"context_line":"    @cpo.event_wrapper(True, step\u003d_(\"Await agents\"), param\u003d(\u0027cluster\u0027, 1))"},{"line_number":132,"context_line":"    def await_agents(self, cluster, instances):"},{"line_number":133,"context_line":"        api \u003d self.get_api_client(instances[0].cluster)"},{"line_number":134,"context_line":"        poll_utils.plugin_poll("},{"line_number":135,"context_line":"            cluster, self.agents_connected, c_helper.AWAIT_AGENTS_TIMEOUT,"}],"source_content_type":"text/x-python","patch_set":3,"id":"9a80dd14_edcc0638","line":132,"updated":"2015-03-05 08:48:57.000000000","message":"May be it\u0027s a good idea to add some LOG input here? DEBUG level would be fine","commit_id":"34071b690910ea7c269f2c0997a4e76aae82abc8"}],"sahara/plugins/cdh/v5/config_helper.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":93,"context_line":"                 \"The file will be downloaded from VM with oozie.\"))"},{"line_number":94,"context_line":""},{"line_number":95,"context_line":"AWAIT_AGENTS_TIMEOUT \u003d p.Config("},{"line_number":96,"context_line":"    \u0027Await Cloudera Agents timeout\u0027, \u0027general\u0027, \u0027cluster\u0027, config_type\u003d\u0027int\u0027,"},{"line_number":97,"context_line":"    priority\u003d1, default_value\u003d300, is_optional\u003dTrue,"},{"line_number":98,"context_line":"    description\u003d\u0027Timeout for waiting for Cloudera agents connected to Cloudera\u0027"},{"line_number":99,"context_line":"                \u0027 Manager\", in seconds\u0027)"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_2959bb8e","line":96,"updated":"2015-03-17 15:27:59.000000000","message":"s/Agents/agents","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"},{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":96,"context_line":"    \u0027Await Cloudera Agents timeout\u0027, \u0027general\u0027, \u0027cluster\u0027, config_type\u003d\u0027int\u0027,"},{"line_number":97,"context_line":"    priority\u003d1, default_value\u003d300, is_optional\u003dTrue,"},{"line_number":98,"context_line":"    description\u003d\u0027Timeout for waiting for Cloudera agents connected to Cloudera\u0027"},{"line_number":99,"context_line":"                \u0027 Manager\", in seconds\u0027)"},{"line_number":100,"context_line":""},{"line_number":101,"context_line":"AWAIT_MANAGER_STARTING_TIMEOUT \u003d p.Config("},{"line_number":102,"context_line":"    \u0027Timeout for Cloudera Manager starting\u0027, \u0027general\u0027, \u0027cluster\u0027,"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_c9f73f58","line":99,"updated":"2015-03-17 15:27:59.000000000","message":"this description should probably be:\n\n    Timeout for Cloudera agents connecting to Coudera Manager, in seconds","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"}],"sahara/plugins/cdh/v5_3_0/cloudera_utils.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7152bbefa44a0e6b95d564d298c8e0880f0908d4","unresolved":false,"context_lines":[{"line_number":162,"context_line":"            cm_cluster.create_service(self.IMPALA_SERVICE_NAME,"},{"line_number":163,"context_line":"                                      IMPALA_SERVICE_TYPE)"},{"line_number":164,"context_line":""},{"line_number":165,"context_line":"    def is_agents_connected(self, cluster, instances, api):"},{"line_number":166,"context_line":"        hostnames \u003d [i.fqdn() for i in instances]"},{"line_number":167,"context_line":"        hostnames_to_manager \u003d [h.hostname for h in"},{"line_number":168,"context_line":"                                api.get_all_hosts(\u0027full\u0027)]"}],"source_content_type":"text/x-python","patch_set":2,"id":"ba7be1f8_d5de5ed9","line":165,"updated":"2015-03-04 00:33:27.000000000","message":"again, name issue","commit_id":"32e8f73c881e8b60ae1bfa52f801eaf327e8711d"},{"author":{"_account_id":7535,"name":"Nikolay Starodubtsev","email":"starodubcevna@gmail.com","username":"Kezar"},"change_message_id":"c0493da36f4baf763a6cfe1e6b9e6146331a2cdc","unresolved":false,"context_lines":[{"line_number":147,"context_line":"            cm_cluster.create_service(self.IMPALA_SERVICE_NAME,"},{"line_number":148,"context_line":"                                      IMPALA_SERVICE_TYPE)"},{"line_number":149,"context_line":""},{"line_number":150,"context_line":"    def agents_connected(self, cluster, instances, api):"},{"line_number":151,"context_line":"        hostnames \u003d [i.fqdn() for i in instances]"},{"line_number":152,"context_line":"        hostnames_to_manager \u003d [h.hostname for h in"},{"line_number":153,"context_line":"                                api.get_all_hosts(\u0027full\u0027)]"}],"source_content_type":"text/x-python","patch_set":3,"id":"9a80dd14_cd63c218","line":150,"updated":"2015-03-05 08:48:57.000000000","message":"logs here","commit_id":"34071b690910ea7c269f2c0997a4e76aae82abc8"},{"author":{"_account_id":7535,"name":"Nikolay Starodubtsev","email":"starodubcevna@gmail.com","username":"Kezar"},"change_message_id":"c0493da36f4baf763a6cfe1e6b9e6146331a2cdc","unresolved":false,"context_lines":[{"line_number":157,"context_line":"        return True"},{"line_number":158,"context_line":""},{"line_number":159,"context_line":"    @cpo.event_wrapper(True, step\u003d_(\"Await agents\"), param\u003d(\u0027cluster\u0027, 1))"},{"line_number":160,"context_line":"    def await_agents(self, cluster, instances):"},{"line_number":161,"context_line":"        api \u003d self.get_api_client(instances[0].cluster)"},{"line_number":162,"context_line":"        poll_utils.plugin_poll("},{"line_number":163,"context_line":"            cluster, self.agents_connected, c_helper.AWAIT_AGENTS_TIMEOUT,"}],"source_content_type":"text/x-python","patch_set":3,"id":"9a80dd14_2d737eea","line":160,"updated":"2015-03-05 08:48:57.000000000","message":"and may be here","commit_id":"34071b690910ea7c269f2c0997a4e76aae82abc8"},{"author":{"_account_id":12707,"name":"Jacob Bin Wang","email":"wangbin@awcloud.com","username":"Jacob"},"change_message_id":"4f1028f5cfd1de7969c96f962547e75e06c9314e","unresolved":false,"context_lines":[{"line_number":147,"context_line":"            cm_cluster.create_service(self.IMPALA_SERVICE_NAME,"},{"line_number":148,"context_line":"                                      IMPALA_SERVICE_TYPE)"},{"line_number":149,"context_line":""},{"line_number":150,"context_line":"    def agents_connected(self, cluster, instances, api):"},{"line_number":151,"context_line":"        hostnames \u003d [i.fqdn() for i in instances]"},{"line_number":152,"context_line":"        hostnames_to_manager \u003d [h.hostname for h in"},{"line_number":153,"context_line":"                                api.get_all_hosts(\u0027full\u0027)]"}],"source_content_type":"text/x-python","patch_set":4,"id":"9a80dd14_2ef36a9f","line":150,"updated":"2015-03-05 13:01:15.000000000","message":"ditto with param cluster","commit_id":"ef9a00e0d814667b54447398fa2be47bbe7c780f"}],"sahara/plugins/cdh/v5_3_0/config_helper.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":150,"context_line":"                 \"The file will be downloaded from VM with oozie.\"))"},{"line_number":151,"context_line":""},{"line_number":152,"context_line":"AWAIT_AGENTS_TIMEOUT \u003d p.Config("},{"line_number":153,"context_line":"    \u0027Await Cloudera Agents timeout\u0027, \u0027general\u0027, \u0027cluster\u0027, config_type\u003d\u0027int\u0027,"},{"line_number":154,"context_line":"    priority\u003d1, default_value\u003d300, is_optional\u003dTrue,"},{"line_number":155,"context_line":"    description\u003d\u0027Timeout for waiting for Cloudera agents connected to Cloudera\u0027"},{"line_number":156,"context_line":"                \u0027 Manager\", in seconds\u0027)"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_a9a84b21","line":153,"updated":"2015-03-17 15:27:59.000000000","message":"s/Agents/agents","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"},{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":153,"context_line":"    \u0027Await Cloudera Agents timeout\u0027, \u0027general\u0027, \u0027cluster\u0027, config_type\u003d\u0027int\u0027,"},{"line_number":154,"context_line":"    priority\u003d1, default_value\u003d300, is_optional\u003dTrue,"},{"line_number":155,"context_line":"    description\u003d\u0027Timeout for waiting for Cloudera agents connected to Cloudera\u0027"},{"line_number":156,"context_line":"                \u0027 Manager\", in seconds\u0027)"},{"line_number":157,"context_line":""},{"line_number":158,"context_line":"AWAIT_MANAGER_STARTING_TIMEOUT \u003d p.Config("},{"line_number":159,"context_line":"    \u0027Timeout for Cloudera Manager starting\u0027, \u0027general\u0027, \u0027cluster\u0027,"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_c97c9fb8","line":156,"updated":"2015-03-17 15:27:59.000000000","message":"this description should probably be:\n\n    Timeout for Cloudera agents connecting to Cloudera Manager, in seconds","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"}],"sahara/plugins/cdh/v5_3_0/plugin_utils.py":[{"author":{"_account_id":7710,"name":"Sergey Reshetnyak","email":"sreshetniak@mirantis.com","username":"sreshetniak"},"change_message_id":"a4d14256e870c2aefda4b4f7d37d5504c121a202","unresolved":false,"context_lines":[{"line_number":132,"context_line":"        with manager.remote() as r:"},{"line_number":133,"context_line":"            self.db_helper.create_sentry_database(cluster, r)"},{"line_number":134,"context_line":""},{"line_number":135,"context_line":"    def check_cloudera_manager_started(self, manager):"},{"line_number":136,"context_line":"        try:"},{"line_number":137,"context_line":"            conn \u003d telnetlib.Telnet(manager.management_ip, CM_API_PORT)"},{"line_number":138,"context_line":"            conn.close()"}],"source_content_type":"text/x-python","patch_set":8,"id":"9a80dd14_33440a46","line":135,"updated":"2015-03-16 13:12:51.000000000","message":"sahara/plugins/cdh/v5/plugin_utils.py file contains same code. I think should refactor it.","commit_id":"8b5364183dbf9e002865e728a3f233b97d299938"}],"sahara/plugins/vanilla/hadoop2/config_helper.py":[{"author":{"_account_id":7710,"name":"Sergey Reshetnyak","email":"sreshetniak@mirantis.com","username":"sreshetniak"},"change_message_id":"a4d14256e870c2aefda4b4f7d37d5504c121a202","unresolved":false,"context_lines":[{"line_number":127,"context_line":""},{"line_number":128,"context_line":""},{"line_number":129,"context_line":"DATANODES_DECOMMISSIONING_TIMEOUT \u003d p.Config("},{"line_number":130,"context_line":"    \u0027DataNodes decommissioning Timeout\u0027, \u0027general\u0027,"},{"line_number":131,"context_line":"    \u0027cluster\u0027, config_type\u003d\u0027int\u0027, priority\u003d1,"},{"line_number":132,"context_line":"    default_value\u003d3600 * 4, is_optional\u003dTrue,"},{"line_number":133,"context_line":"    description\u003d\u0027Timeout for datanode decommissioning operation\u0027"}],"source_content_type":"text/x-python","patch_set":8,"id":"9a80dd14_13b7063b","line":130,"range":{"start_line":130,"start_character":31,"end_line":130,"end_character":32},"updated":"2015-03-16 13:12:51.000000000","message":"timeout","commit_id":"8b5364183dbf9e002865e728a3f233b97d299938"},{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":127,"context_line":""},{"line_number":128,"context_line":""},{"line_number":129,"context_line":"DATANODES_DECOMMISSIONING_TIMEOUT \u003d p.Config("},{"line_number":130,"context_line":"    \u0027DataNodes decommissioning Timeout\u0027, \u0027general\u0027,"},{"line_number":131,"context_line":"    \u0027cluster\u0027, config_type\u003d\u0027int\u0027, priority\u003d1,"},{"line_number":132,"context_line":"    default_value\u003d3600 * 4, is_optional\u003dTrue,"},{"line_number":133,"context_line":"    description\u003d\u0027Timeout for datanode decommissioning operation\u0027"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_493fcfd6","line":130,"updated":"2015-03-17 15:27:59.000000000","message":"s/Timeout/timeout","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"},{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7c4df97627cbe4c2aed734a6fbf33873f622f4f9","unresolved":false,"context_lines":[{"line_number":135,"context_line":""},{"line_number":136,"context_line":""},{"line_number":137,"context_line":"NODEMANAGERS_DECOMMISSIONING_TIMEOUT \u003d p.Config("},{"line_number":138,"context_line":"    \u0027NodeManagers decommissioning Timeout\u0027, \u0027general\u0027,"},{"line_number":139,"context_line":"    \u0027cluster\u0027, config_type\u003d\u0027int\u0027, priority\u003d1,"},{"line_number":140,"context_line":"    default_value\u003d300, is_optional\u003dTrue,"},{"line_number":141,"context_line":"    description\u003d\u0027Timeout for NodeManager decommissioning operation\u0027"}],"source_content_type":"text/x-python","patch_set":10,"id":"9a80dd14_c92adf8f","line":138,"updated":"2015-03-17 15:27:59.000000000","message":"s/Timeout/timeout","commit_id":"75a014e2dd4686ebe0e1e6bb62cbf49832386f90"}],"sahara/plugins/vanilla/hadoop2/run_scripts.py":[{"author":{"_account_id":10670,"name":"Michael McCune","email":"elmiko@redhat.com","username":"mimccune"},"change_message_id":"7152bbefa44a0e6b95d564d298c8e0880f0908d4","unresolved":false,"context_lines":[{"line_number":146,"context_line":"    datanodes_count \u003d len(vu.get_datanodes(cluster))"},{"line_number":147,"context_line":"    if datanodes_count \u003c 1:"},{"line_number":148,"context_line":"        return"},{"line_number":149,"context_line":"    l_message \u003d _(\"Waiting %s datanodes to start up\") % datanodes_count"},{"line_number":150,"context_line":"    with vu.get_namenode(cluster).remote() as r:"},{"line_number":151,"context_line":"        poll_utils.plugin_poll("},{"line_number":152,"context_line":"            cluster, _check_datanodes_count,"}],"source_content_type":"text/x-python","patch_set":2,"id":"ba7be1f8_f5be0264","line":149,"updated":"2015-03-04 00:33:27.000000000","message":"this should read:\n\n    Waiting on %s datanodes to start up","commit_id":"32e8f73c881e8b60ae1bfa52f801eaf327e8711d"},{"author":{"_account_id":7535,"name":"Nikolay Starodubtsev","email":"starodubcevna@gmail.com","username":"Kezar"},"change_message_id":"c0493da36f4baf763a6cfe1e6b9e6146331a2cdc","unresolved":false,"context_lines":[{"line_number":146,"context_line":"    datanodes_count \u003d len(vu.get_datanodes(cluster))"},{"line_number":147,"context_line":"    if datanodes_count \u003c 1:"},{"line_number":148,"context_line":"        return"},{"line_number":149,"context_line":"    l_message \u003d _(\"Waiting on %s datanodes to start up\") % datanodes_count"},{"line_number":150,"context_line":"    with vu.get_namenode(cluster).remote() as r:"},{"line_number":151,"context_line":"        poll_utils.plugin_poll("},{"line_number":152,"context_line":"            cluster, _check_datanodes_count,"}],"source_content_type":"text/x-python","patch_set":3,"id":"9a80dd14_0d3cfae1","line":149,"updated":"2015-03-05 08:48:57.000000000","message":"use https://www.python.org/dev/peps/pep-3101/ standart here, it\u0027s easier to read.","commit_id":"34071b690910ea7c269f2c0997a4e76aae82abc8"},{"author":{"_account_id":12707,"name":"Jacob Bin Wang","email":"wangbin@awcloud.com","username":"Jacob"},"change_message_id":"4f1028f5cfd1de7969c96f962547e75e06c9314e","unresolved":false,"context_lines":[{"line_number":154,"context_line":"            datanodes_count)"},{"line_number":155,"context_line":""},{"line_number":156,"context_line":""},{"line_number":157,"context_line":"def _check_datanodes_count(cluster, remote, count):"},{"line_number":158,"context_line":"    if count \u003c 1:"},{"line_number":159,"context_line":"        return True"},{"line_number":160,"context_line":""}],"source_content_type":"text/x-python","patch_set":4,"id":"9a80dd14_4ec41e5f","line":157,"updated":"2015-03-05 13:01:15.000000000","message":"\u0027cluster\u0027 is unused.","commit_id":"ef9a00e0d814667b54447398fa2be47bbe7c780f"}]}