nifi执行SQL连接到hana在创建avro模式时失败

Question

查看代码时，在需要为avro架构转换的未定义数据类型上引发错误。然而，我选择的唯一一列是代码中的NVARCHAR（5000）类型。

2017-04-21 01:33:51,446 WARN[Timer-Driven Process Thread-1]o. a. n. c. t. ContinuallyRunProcessorTaskjava.lang.IllegalArgumentException： createSchema： Unknown SQL type 2011无法转换为Avro type atorg.apache.nifi.processors.standard.util.JdbcCommon.createSchema（JdbcCommon.java:349）~[na： na]atorg.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream（JdbcCommon.java:92）~[na： na]atorg.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream（JdbcCommon.java:87）~[na： na]atorg.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream（JdbcCommon.java:77）~[na： na]atorg.apache.nifi.processors.standard.ExcuteSQL$2.process（ExecteL. SQjava： 205）~[na： na]atorg.apache.nifi.controller.repository.Standard ardProcessSession.write（Standard ardProcessSession.java:2329）~[nifi-framework-core-1.1.2.jar： 1.1.2]atorg.apache.nifi.processors.standard.ExecteSQL. onTrigger（ExecteSQL. java： 199）~执行者$RunnableAdapter. call（Executors. java： 511）[na： 1.8.0_102]在java. util. concurrent. FutureTask. runAndReset（FutureTask. java： 308）[na： 1.8.0_102]在java. util. concurrent. schduledThreadPoolExector$schduledFutureTask. access 301美元（SchduledThreadPoolExecutor. java： 180）[na： 1.8.0_102]在java. util. concurrent. schduledThreadPoolExecitor$SchduledFutureTask. run（SchduledThreadPoolExecutor. java： 294）[na： 1.8.0_102]在java. util. concurrent. ThreadPoolExecutor. runWorker（ThreadPoolExecutor. java： 1142）[na： 1.8.0_102]在java. util. concurrent. ThreadPoolExecutor$

Answer 1

在JDK8的JDBC API中，NCLOB是2011，NVARCHAR是-9：

public static final int NCLOB = 2011;
public static final int NVARCHAR = -9;

看起来你正在使用的驱动程序正在返回2011年的专栏，尽管你认为该专栏是NVARCHAR。我不完全确定，但这似乎是hana司机的错误行为。

通过在JdbcCommon中的case语句中添加NCLOB，可能可以在NiFi方面处理这个问题：

 case CHAR:
 case LONGNVARCHAR:
 case LONGVARCHAR:
 case NCHAR:
 case NVARCHAR:
 case VARCHAR:
 case CLOB: