Задание фида Kylo data_ingest не выполнено из-за отказа в доступе для пользователя 'root'@'localhost' (с использованием пароля: НЕТ)

Question

• Я установил шаблон по умолчанию из установочного каталога Kylo для 'data_ingest' в пользовательском интерфейсе Kylo - http://localhost:8400/

• Используя шаблон, я создал канал для извлечения данных из базы данных (MySQL), указав базу данных / таблицу / столбцы в сведениях о канале.

• База данных была выбрана из выпадающего списка, я дал все конфигурации внутри /opt/kylo/kylo-services/application.properties

  spring.datasource.username=root
  spring.datasource.password=cloudera
  ..
  hive.metastore.datasource.username=root
  hive.metastore.datasource.password=cloudera
  

Несмотря на это, у меня не получается с последующей ошибкой -

GetTableData[id=a3eb6450-1f53-3e1e-a523-01db02f0b625] Unable to execute SQL select from table due to StandardFlowFileRecord[uuid=27219d8a-9bef-40be-a413-63d4d8663ebe,claim=,offset=0,name=32633830193154,size=0]; routing to failure: org.apache.nifi.processor.exception.ProcessException: org.apache.commons.dbcp.SQLNestedException: Cannot create PoolableConnectionFactory (Could not connect: Access denied for user 'root'@'localhost' (using password: NO))

Есть ли какая-либо конфигурация, которую я пропускаю, вызывая эту ошибку?

Answer 1

Чтобы решить эту проблему, предоставьте учетные данные для подключения к базе данных через службу контроллера. Шаги ниже:

1. Перейдите к NiFi ( http://localhost:8079/nifi).
2. Нажмите значок шестеренки в группе процессов NiFi Flow на холсте. Откроется страница конфигурации группы процессов.

3. Перейдите на вкладку " Услуги контроллера ".
4. Найдите службу типа DBCPConnectionPool. В зависимости от версии Kylo это может называться MySQL или Kylo MySQL.

5. Отключите службу, нажав значок молнии и нажав кнопку Отключить. Нажмите Закрыть после того, как служба отключена.

6. Откройте конфигурацию сервиса, щелкнув значок карандаша. Это откроет всплывающее окно Configure Controller Service.

7. Укажите правильные имя пользователя и пароль базы данных для свойств Database User и Password.

8. Нажмите Применить. Всплывающее окно конфигурации закроется.
9. Чтобы включить службу, щелкните значок молнии, выберите " Служба" и "Ссылки на компоненты" в раскрывающемся списке " Область" и нажмите " Включить". Нажмите Закрыть после включения сервиса.

10. Запустите канал снова.