Member since
03-18-2017
2
Posts
0
Kudos Received
0
Solutions
03-18-2017
10:40 PM
I am trying to use this processor to access HBase client and getting errors (implementing custom increment). Wonder if you have any tips on this (hbase specific I am just trying to implement increment HBase script but can not seem to figure out how to get already functioning HBase connection. Caused by: groovy.lang.MissingMethodException: No signature of method: com.sun.proxy.$Proxy83.getConnection() is applicable for argument types: () values: [] on this code import org.apache.nifi.controller.ControllerService
flowFile = session.get() if(!flowFile) return def lookup = context.controllerServiceLookup
defHbaseServiceName=HBaseConnectionName.value
defHBaseServiceId= lookup.getControllerServiceIdentifiers(ControllerService).find {
cs -> lookup.getControllerServiceName(cs)==HbaseServiceName } def conn = lookup.getControllerService(HBaseServiceId)?.getConnection()
... View more