hadoop - ExecuteSQL 什么都不做

Question

我正在尝试通过 Nifi 从 oracle 数据库中获取数据。在 Canvas 中，我将文件大小为 0 KB 的“GenerateFlowFile”处理器安排为每 5 分钟运行一次。这只是为了在成功时触发“ExecuteSQL”处理器。对于“ExecuteSQL”，我将数据库连接池服务设置为 DBCPConnectionPool。我输入了 SQL 查询“SELECT * FROM SOMETABLE”。我的DBCPConnectionPool配置如下:

URL = jdbc:oracle:thin:@hostname:port:sid
Driver = oracle.jdbc.driver.OracleDriver
Jar URL = file:///somelocation/ojdbc6.jar
User = someuser
Password = somepassword

当我尝试运行时，没有任何反应。红色框变为绿色，“ExecuteSQL”处理器右上角有一个数字 1。但是没有任何反应。然后当我停止它时，事件线程仍然是 1。
可以请告诉我，因为我是新手吗？谢谢。

Answer 1

既然原来的帖子已经回答了，我会在评论中回复这个问题:

您可以将 GenerateFlowFile 处理器设置为每 30 秒左右运行一次，然后启动并立即停止。这将导致 ExecuteSQL 只运行一次，获取所有行。

或者(在 NiFi 0.6.0+ 中)您可以使用 QueryDbTable处理器，它将第一次获取所有行，但随后(基于最大值列，如递增的主键)仅返回添加的行。