尝试连接到hbase服务时出现此错误。我只是在尝试实现增量hbase脚本,但似乎不知道如何获得已经运行的hbase连接。
原因:groovy.lang.missingmethodexception:没有方法的签名:com.sun.proxy.$proxy83.getconnection()适用于此代码上的参数类型:()值:[]
import org.apache.nifi.controller.ControllerService
flowFile = session.get()
if(!flowFile) return
def lookup = context.controllerServiceLookup
def HbaseServiceName = HBaseConnectionName.value
def HBaseServiceId = lookup.getControllerServiceIdentifiers(ControllerService).find {
cs -> lookup.getControllerServiceName(cs) == HbaseServiceName
}
def conn = lookup.getControllerService(HBaseServiceId)?.getConnection()
暂无答案!
目前还没有任何答案,快来回答吧!