无法使用execute脚本连接到hbase

lp0sw83n  于 2021-06-10  发布在  Hbase
关注(0)|答案(0)|浏览(213)

尝试连接到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()

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题