0

我正在使用 Apache Nifi 1.3.0,我正在使用 ExecuteSql 处理器从 MS SQLjdbc:jtds:sqlserver://IP:1433/DBNAME数据库中读取记录。

问题是,只有当我的 SQL 语句没有 where 子句时,我才能使用 ExecuteSql 处理器从 MS SQL 中检索记录,例如,select * from Table但是当我使用像select * from Table where ID > 10ExecuteSql 处理器这样的 SQL 语句无法获得结果时,我得到的只是空的 Avro 模式记录。

Objavro.schema▒{"type":"record","name":"NiFi_ExecuteSQL_Record","namespace":"any.data","fields":[{"name":"ID","type":["null","int"]},{"name":"COL1","type":["null","long"]},{"name":"COL2","type":["null","int"]},{"name":"COL3","type":["null","int"]},{"name":"COL4","type":["null","int"]}]}G▒▒@▒[ж▒6
4

0 回答 0