0
  • 我已经从 Kylo 安装目录中为 kylo UI 上的“data_ingest”设置了一个默认模板 - http://localhost:8400

  • 使用模板,我创建了一个 Feed 以从数据库 (MySQL) 中获取数据,并在 Feed 详细信息中指定数据库/表/列。

  • 数据库是从下拉列表中选择的,我在 /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))

在此处输入图像描述

我是否缺少任何导致此错误的配置?

4

1 回答 1

5

要解决此问题,请提供通过控制器服务连接到数据库的凭据。步骤如下:

  1. 导航到 NiFi ( http://localhost:8079/nifi/ )。
  2. 单击画布上NiFi Flow进程组上的齿轮图标。这将打开进程组配置页面。

在此处输入图像描述

  1. 导航到控制器服务选项卡。
  2. 找到DBCPConnectionPool类型的服务。根据 Kylo 的版本,这可能被命名为MySQLKylo MySQL

在此处输入图像描述

  1. 通过单击闪电图标并单击禁用按钮禁用该服务。禁用服务后单击关闭

在此处输入图像描述

  1. 通过单击铅笔图标打开服务配置。这将打开配置控制器服务弹出窗口。

在此处输入图像描述

  1. 为属性数据库用户密码提供正确的数据库用户名和密码值

在此处输入图像描述

  1. 单击应用。配置弹出窗口将关闭。
  2. 通过单击闪电图标、从范围下拉列表中选择服务和引用组件并单击启用来启用服务。启用服务后单击关闭。

在此处输入图像描述

  1. 再次运行提要。
于 2017-09-06T20:01:06.417 回答