-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/53671/
-----------------------------------------------------------
Review request for Ambari, Andrew Onischuk, Dmitro Lisnichenko, Dmytro Sen, and
Sumit Mohanty.
Bugs: AMBARI-18862
https://issues.apache.org/jira/browse/AMBARI-18862
Repository: ambari
Description
-------
KAFKA broker start failed during restart stale config services after updating
log directory.
Test scenario:
1. Update Kafka log directory to /grid/0/_QE-7627_/_logRMP5891_/KAFKA
2. Restart stale components using API
3. All components with stale config should be restarted successfully. but
restart KAFKA_BROKER service is failed with error: Source file
/var/log/kafka/audit is not found",
{noformat}
"stderr" : "Traceback (most recent call last):\n
File
\"/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.py\",
line 129, in <module>\n
KafkaBroker().execute()\n
File
\"/usr/lib/python2.6/site-packages/resource_management/libraries/script/script.py\",
line 280, in execute\n
method(env)\n
File
\"/usr/lib/python2.6/site-packages/resource_management/libraries/script/script.py\",
line 720, in restart\n
self.start(env, upgrade_type=upgrade_type)\n
File
\"/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.py\",
line 81, in start\n
self.configure(env, upgrade_type=upgrade_type)\n
File
\"/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.py\",
line 49, in configure\n
kafka(upgrade_type=upgrade_type)\n
File
\"/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka.py\",
line 169, in kafka\n
setup_symlink(params.kafka_managed_log_dir, params.kafka_log_dir)\n
File
\"/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka.py\",
line 188, in setup_symlink\n
backup_folder_path = backup_dir_contents(kafka_managed_dir,
backup_folder_suffix)\n
File
\"/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka.py\",
line 244, in backup_dir_contents\n\
content = StaticFile(os.path.join(dir_path,file)))\n
File \"/usr/lib/python2.6/site-packages/resource_management/core/base.py\",
line 155, in __init__\n
self.env.run()\n
File
\"/usr/lib/python2.6/site-packages/resource_management/core/environment.py\",
line 160, in run\n
self.run_action(resource, action)\n
File
\"/usr/lib/python2.6/site-packages/resource_management/core/environment.py\",
line 124, in run_action\n
provider_action()\n File
\"/usr/lib/python2.6/site-packages/resource_management/core/providers/system.py\",
line 123, in action_create\n
content = self._get_content()\n File
\"/usr/lib/python2.6/site-packages/resource_management/core/providers/system.py\",
line 160, in _get_content\n
return content()\n File
\"/usr/lib/python2.6/site-packages/resource_management/core/source.py\", line
51, in __call__\n
return self.get_content()\n File
\"/usr/lib/python2.6/site-packages/resource_management/core/source.py\", line
75, in get_content\n
raise Fail(\"{0} Source file {1} is not found\".format(repr(self),
path))\nresource_management.core.exceptions.Fail:
StaticFile('/var/log/kafka/audit') Source file /var/log/kafka/audit is not
found",
{noformat}
Diffs
-----
ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/kafka.py
ac7b0ae
Diff: https://reviews.apache.org/r/53671/diff/
Testing
-------
mvn clean test
Thanks,
Vitalyi Brodetskyi
