Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
2.4.2
-
None
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",
"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",
Attachments
Attachments
Issue Links
- links to