我正在尝试将具有分区的多个表中的数据从同一数据库加载到另一个表。为此,我遵循以下程序:
ListDatabaseTables --> RouteOnAttribute --> Replacetext --> ExecuteSQL --> PutHive3Streaming
在 executeSQL 处理器中,出现以下异常:
unable to execute SQL select query `select * from test.department1 where dt='20190901'` due to java.sql.SQLFeatureNotSuppoertedException:method not supported; routing to failure:org.apache.nifi.procssor.exception.processException:java.sql.SQLFeaturenotSupportedException: Method not Supported.
在 Replacetext 处理器中,我的查询如下:
select * from '${$db.table.fullname}'