zoukankan      html  css  js  c++  java
  • Kettle jdbc连接hive出现问题

    jdbc连接时报如下错误:

    Error connecting to database [k] : org.pentaho.di.core.exception.KettleDatabaseException: 
    Error occurred while trying to connect to the database
    
    Error connecting to database: (using class org.apache.hive.jdbc.HiveDriver)
    Failed to open new session: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    
    
    org.pentaho.di.core.exception.KettleDatabaseException: 
    Error occurred while trying to connect to the database
    
    Error connecting to database: (using class org.apache.hive.jdbc.HiveDriver)
    Failed to open new session: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    
    
    	at org.pentaho.di.core.database.Database.normalConnect(Database.java:466)
    	at org.pentaho.di.core.database.Database.connect(Database.java:364)
    	at org.pentaho.di.core.database.Database.connect(Database.java:335)
    	at org.pentaho.di.core.database.Database.connect(Database.java:325)
    	at org.pentaho.di.core.database.DatabaseFactory.getConnectionTestReport(DatabaseFactory.java:80)
    	at org.pentaho.di.core.database.DatabaseMeta.testConnection(DatabaseMeta.java:2734)
    	at org.pentaho.ui.database.event.DataHandler.testDatabaseConnection(DataHandler.java:591)
    	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:606)
    	at org.pentaho.ui.xul.impl.AbstractXulDomContainer.invoke(AbstractXulDomContainer.java:313)
    	at org.pentaho.ui.xul.impl.AbstractXulComponent.invoke(AbstractXulComponent.java:157)
    	at org.pentaho.ui.xul.impl.AbstractXulComponent.invoke(AbstractXulComponent.java:141)
    	at org.pentaho.ui.xul.swt.tags.SwtButton.access$500(SwtButton.java:43)
    	at org.pentaho.ui.xul.swt.tags.SwtButton$4.widgetSelected(SwtButton.java:137)
    	at org.eclipse.swt.widgets.TypedListener.handleEvent(Unknown Source)
    	at org.eclipse.swt.widgets.EventTable.sendEvent(Unknown Source)
    	at org.eclipse.swt.widgets.Widget.sendEvent(Unknown Source)
    	at org.eclipse.swt.widgets.Display.runDeferredEvents(Unknown Source)
    	at org.eclipse.swt.widgets.Display.readAndDispatch(Unknown Source)
    	at org.eclipse.jface.window.Window.runEventLoop(Window.java:820)
    	at org.eclipse.jface.window.Window.open(Window.java:796)
    	at org.pentaho.di.ui.xul.KettleDialog.show(KettleDialog.java:88)
    	at org.pentaho.di.ui.xul.KettleDialog.show(KettleDialog.java:55)
    	at org.pentaho.di.ui.core.database.dialog.XulDatabaseDialog.open(XulDatabaseDialog.java:116)
    	at org.pentaho.di.ui.core.database.dialog.DatabaseDialog.open(DatabaseDialog.java:60)
    	at org.pentaho.di.ui.spoon.delegates.SpoonDBDelegate.newConnection(SpoonDBDelegate.java:474)
    	at org.pentaho.di.ui.spoon.delegates.SpoonDBDelegate.newConnection(SpoonDBDelegate.java:461)
    	at org.pentaho.di.ui.spoon.Spoon.doubleClickedInTree(Spoon.java:3059)
    	at org.pentaho.di.ui.spoon.Spoon.doubleClickedInTree(Spoon.java:3029)
    	at org.pentaho.di.ui.spoon.Spoon.access$2400(Spoon.java:356)
    	at org.pentaho.di.ui.spoon.Spoon$27.widgetDefaultSelected(Spoon.java:6109)
    	at org.eclipse.swt.widgets.TypedListener.handleEvent(Unknown Source)
    	at org.eclipse.swt.widgets.EventTable.sendEvent(Unknown Source)
    	at org.eclipse.swt.widgets.Widget.sendEvent(Unknown Source)
    	at org.eclipse.swt.widgets.Display.runDeferredEvents(Unknown Source)
    	at org.eclipse.swt.widgets.Display.readAndDispatch(Unknown Source)
    	at org.pentaho.di.ui.spoon.Spoon.readAndDispatch(Spoon.java:1347)
    	at org.pentaho.di.ui.spoon.Spoon.waitForDispose(Spoon.java:7989)
    	at org.pentaho.di.ui.spoon.Spoon.start(Spoon.java:9269)
    	at org.pentaho.di.ui.spoon.Spoon.main(Spoon.java:662)
    	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:606)
    	at org.pentaho.commons.launcher.Launcher.main(Launcher.java:92)
    Caused by: org.pentaho.di.core.exception.KettleDatabaseException: 
    Error connecting to database: (using class org.apache.hive.jdbc.HiveDriver)
    Failed to open new session: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    
    	at org.pentaho.di.core.database.Database.connectUsingClass(Database.java:579)
    	at org.pentaho.di.core.database.Database.normalConnect(Database.java:450)
    	... 46 more
    Caused by: org.apache.hive.service.cli.HiveSQLException: Failed to open new session: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    	at org.apache.hive.jdbc.Utils.verifySuccess(Utils.java:258)
    	at org.apache.hive.jdbc.Utils.verifySuccess(Utils.java:249)
    	at org.apache.hive.jdbc.HiveConnection.openSession(HiveConnection.java:565)
    	at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:171)
    	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:105)
    	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:606)
    	at org.pentaho.hadoop.shim.common.DriverProxyInvocationChain$DriverInvocationHandler.invoke(DriverProxyInvocationChain.java:206)
    	at com.sun.proxy.$Proxy64.connect(Unknown Source)
    	at org.apache.hive.jdbc.HiveDriver$1.call(HiveDriver.java:153)
    	at org.apache.hive.jdbc.HiveDriver$1.call(HiveDriver.java:150)
    	at org.pentaho.hadoop.hive.jdbc.JDBCDriverCallable.callWithDriver(JDBCDriverCallable.java:57)
    	at org.apache.hive.jdbc.HiveDriver.callWithActiveDriver(HiveDriver.java:130)
    	at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:150)
    	at java.sql.DriverManager.getConnection(DriverManager.java:571)
    	at java.sql.DriverManager.getConnection(DriverManager.java:233)
    	at org.pentaho.di.core.database.Database.connectUsingClass(Database.java:565)
    	... 47 more
    Caused by: org.apache.hive.service.cli.HiveSQLException: Failed to open new session: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    	at org.apache.hive.service.cli.session.SessionManager.openSession(SessionManager.java:266)
    	at org.apache.hive.service.cli.CLIService.openSessionWithImpersonation(CLIService.java:202)
    	at org.apache.hive.service.cli.thrift.ThriftCLIService.getSessionHandle(ThriftCLIService.java:402)
    	at org.apache.hive.service.cli.thrift.ThriftCLIService.OpenSession(ThriftCLIService.java:297)
    	at org.apache.hive.service.cli.thrift.TCLIService$Processor$OpenSession.getResult(TCLIService.java:1253)
    	at org.apache.hive.service.cli.thrift.TCLIService$Processor$OpenSession.getResult(TCLIService.java:1238)
    	at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
    	at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
    	at org.apache.hive.service.auth.TSetIpAddressProcessor.process(TSetIpAddressProcessor.java:56)
    	at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:285)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    	at java.lang.Thread.run(Thread.java:745)
    Caused by: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    	at org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:83)
    	at org.apache.hive.service.cli.session.HiveSessionProxy.access$000(HiveSessionProxy.java:36)
    	at org.apache.hive.service.cli.session.HiveSessionProxy$1.run(HiveSessionProxy.java:63)
    	at java.security.AccessController.doPrivileged(Native Method)
    	at javax.security.auth.Subject.doAs(Subject.java:415)
    	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1657)
    	at org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:59)
    	at com.sun.proxy.$Proxy25.open(Unknown Source)
    	at org.apache.hive.service.cli.session.SessionManager.openSession(SessionManager.java:258)
    	... 12 more
    Caused by: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.authorize.AuthorizationException): Unauthorized connection for super-user: hive from IP
    	at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:494)
    	at org.apache.hive.service.cli.session.HiveSessionImpl.open(HiveSessionImpl.java:137)
    	at sun.reflect.GeneratedMethodAccessor11.invoke(Unknown Source)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:606)
    	at org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:78)
    	... 20 more
    Caused by: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException:Unauthorized connection for super-user: hive from IP
    	at org.apache.hadoop.ipc.Client.call(Client.java:1427)
    	at org.apache.hadoop.ipc.Client.call(Client.java:1358)
    	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:229)
    	at com.sun.proxy.$Proxy19.getFileInfo(Unknown Source)
    	at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.getFileInfo(ClientNamenodeProtocolTranslatorPB.java:771)
    	at sun.reflect.GeneratedMethodAccessor7.invoke(Unknown Source)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:606)
    	at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:252)
    	at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:104)
    	at com.sun.proxy.$Proxy20.getFileInfo(Unknown Source)
    	at org.apache.hadoop.hdfs.DFSClient.getFileInfo(DFSClient.java:2116)
    	at org.apache.hadoop.hdfs.DistributedFileSystem$22.doCall(DistributedFileSystem.java:1315)
    	at org.apache.hadoop.hdfs.DistributedFileSystem$22.doCall(DistributedFileSystem.java:1311)
    	at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81)
    	at org.apache.hadoop.hdfs.DistributedFileSystem.getFileStatus(DistributedFileSystem.java:1311)
    	at org.apache.hadoop.fs.FileSystem.exists(FileSystem.java:1424)
    	at org.apache.hadoop.hive.ql.session.SessionState.createRootHDFSDir(SessionState.java:568)
    	at org.apache.hadoop.hive.ql.session.SessionState.createSessionDirs(SessionState.java:526)
    	at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:480)
    	... 25 more
    
    Hostname       : 
    Port           : 10000
    Database name  : default
    hive is not allowed to impersonate hive

    上述2个错误,刚开始以为hive的jdbc驱动没有,结果看了一下有,并且同样的官网包直接解压在power服务器上没问题,这是在X86,整了半天,最后找到一个网站

    http://www-01.ibm.com/support/docview.wss?uid=swg21972388

    借鉴才解决。

    原因:

    cat /etc/hadoop/conf/core-site.xml
        <property>
          <name>hadoop.proxyuser.hive.groups</name>
          <value>*</value>
        </property>
    
        <property>
          <name>hadoop.proxyuser.hive.hosts</name>
          <value>lh-2.novalocal</value>
        </property>

    原来云主机重启将主机名改成加一个后缀.novalocal,比较坑,安装集群的时候也被坑过。我直接把lh-2.novalocal改成*了,在Ambari上改的。

    然后,重连

    成功!

  • 相关阅读:
    微信小程序之base64转为本地图片
    微信小程序之页面跳转方法
    一些收集的社区网址+学习网站、文档
    11-DOM介绍
    10-关于DOM的事件操作
    09-伪数组 arguments
    前端---css
    前端---html
    并发编程------网络IO模型、IO多路复用
    并发编程------协程
  • 原文地址:https://www.cnblogs.com/zeppelin/p/5817080.html
Copyright © 2011-2022 走看看