[ https://issues.apache.org/jira/browse/AMBARI-21646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andrew Onischuk updated AMBARI-21646: ------------------------------------- Resolution: Fixed Status: Resolved (was: Patch Available) Committed to branch-3.0-perf > Race condition causing execution commands to fail > ------------------------------------------------- > > Key: AMBARI-21646 > URL: https://issues.apache.org/jira/browse/AMBARI-21646 > Project: Ambari > Issue Type: Bug > Reporter: Andrew Onischuk > Assignee: Andrew Onischuk > Fix For: 3.0.0 > > Attachments: AMBARI-21646.patch > > > STR: > 1\. Execution command started > 2\. Registration failed > 3\. Execution command finished. > At this point we try to send an execution command result as not a registered > agent. > Which leads to exception on server or agent. > > > ERROR 2017-08-02 13:36:52,524 ActionQueue.py:207 - Exception while > processing EXECUTION_COMMAND command > Traceback (most recent call last): > File "/usr/lib/python2.6/site-packages/ambari_agent/ActionQueue.py", > line 200, in process_command > self.execute_command(command) > File "/usr/lib/python2.6/site-packages/ambari_agent/ActionQueue.py", > line 410, in execute_command > self.commandStatuses.put_command_status(command, roleResult) > File > "/usr/lib/python2.6/site-packages/ambari_agent/CommandStatusDict.py", line > 59, in put_command_status > self.force_update_to_server(command['clusterId'], new_report) > File > "/usr/lib/python2.6/site-packages/ambari_agent/CommandStatusDict.py", line > 62, in force_update_to_server > > self.initializer_module.connection.send(message={'clusters':{cluster_id: > [report]}}, destination=Constants.COMMANDS_STATUS_REPORTS_ENDPOINT) > File "/usr/lib/python2.6/site-packages/ambari_agent/Utils.py", line > 223, in decorated > v = undecorated(self) > File > "/usr/lib/python2.6/site-packages/ambari_agent/InitializerModule.py", line > 102, in connection > conn.connect(wait=True) > File "/usr/lib/python2.6/site-packages/ambari_stomp/protocol.py", line > 505, in connect > self.transport.wait_for_connection() > File > "/usr/lib/python2.6/site-packages/ambari_stomp/adapter/websocket.py", line > 83, in wait_for_connection > raise ConnectionResponseTimeout("Waiting for connection confirmation > timed out") > ConnectionResponseTimeout: Waiting for connection confirmation timed out > -- This message was sent by Atlassian JIRA (v6.4.14#64029)