这是我和flink社区沟通的记录，你可以看下。
| | 叶贤勋 | | yxx_c...@163.com | 签名由网易邮箱大师定制 在2020年03月3日 16:00，叶贤勋<yxx_c...@163.com> 写道： hive conf应该是对的，前面UserGroupInfomation登录时都是成功的。 datanucleus的依赖不加的话，会报claas not found等异常。 1、java.lang.ClassNotFoundException: org.datanucleus.api.jdo.JDOPersistenceManagerFactory 2、Caused by: org.datanucleus.exceptions.NucleusUserException: There is no available StoreManager of type "rdbms". Please make sure you have specified "datanucleus.storeManagerType" correctly and that all relevant plugins are in the CLASSPATH | | 叶贤勋 | | yxx_c...@163.com | 签名由网易邮箱大师定制 在2020年03月2日 11:50，Rui Li<li...@apache.org> 写道： 从你贴的log来看似乎是创建了embedded metastore。可以检查一下HiveCatalog是不是读到了不正确的hive conf？另外你贴的maven的这些依赖都打到你flink作业的jar里了么？像datanucleus的依赖应该是不需要的。 On Sat, Feb 29, 2020 at 10:42 PM 叶贤勋 <yxx_c...@163.com> wrote: Hi 李锐，感谢你的回复。 前面的问题通过设置yarn.resourcemanager.principal，已经解决。 但是现在出现另外一个问题，请帮忙看看。 背景：flink任务还是source&sink带有kerberos的hive，相同代码在本地进行测试是能通过kerberos认证，并且能够查询和插入数据到hive。但是任务提交到集群就报kerberos认证失败的错误。 Flink：1.9.1, flink-1.9.1/lib/有flink-dist_2.11-1.9.1.jar， flink-shaded-hadoop-2-uber-2.7.5-7.0.jar，log4j-1.2.17.jar， slf4j-log4j12-1.7.15.jar Hive：2.1.1 flink任务主要依赖的jar： [INFO] +- org.apache.flink:flink-table-api-java:jar:flink-1.9.1:compile [INFO] | +- org.apache.flink:flink-table-common:jar:flink-1.9.1:compile [INFO] | | \- org.apache.flink:flink-core:jar:flink-1.9.1:compile [INFO] | | +- org.apache.flink:flink-annotations:jar:flink-1.9.1:compile [INFO] | | +- org.apache.flink:flink-metrics-core:jar:flink-1.9.1:compile [INFO] | | \- com.esotericsoftware.kryo:kryo:jar:2.24.0:compile [INFO] | | +- com.esotericsoftware.minlog:minlog:jar:1.2:compile [INFO] | | \- org.objenesis:objenesis:jar:2.1:compile [INFO] | +- com.google.code.findbugs:jsr305:jar:1.3.9:compile [INFO] | \- org.apache.flink:force-shading:jar:1.9.1:compile [INFO] +- org.apache.flink:flink-table-planner-blink_2.11:jar:flink-1.9.1:compile [INFO] | +- org.apache.flink:flink-table-api-scala_2.11:jar:flink-1.9.1:compile [INFO] | | +- org.scala-lang:scala-reflect:jar:2.11.12:compile [INFO] | | \- org.scala-lang:scala-compiler:jar:2.11.12:compile [INFO] | +- org.apache.flink:flink-table-api-java-bridge_2.11:jar:flink-1.9.1:compile [INFO] | | +- org.apache.flink:flink-java:jar:flink-1.9.1:compile [INFO] | | \- org.apache.flink:flink-streaming-java_2.11:jar:1.9.1:compile [INFO] | +- org.apache.flink:flink-table-api-scala-bridge_2.11:jar:flink-1.9.1:compile [INFO] | | \- org.apache.flink:flink-scala_2.11:jar:flink-1.9.1:compile [INFO] | +- org.apache.flink:flink-table-runtime-blink_2.11:jar:flink-1.9.1:compile [INFO] | | +- org.codehaus.janino:janino:jar:3.0.9:compile [INFO] | | \- org.apache.calcite.avatica:avatica-core:jar:1.15.0:compile [INFO] | \- org.reflections:reflections:jar:0.9.10:compile [INFO] +- org.apache.flink:flink-table-planner_2.11:jar:flink-1.9.1:compile [INFO] +- org.apache.commons:commons-lang3:jar:3.9:compile [INFO] +- com.typesafe.akka:akka-actor_2.11:jar:2.5.21:compile [INFO] | +- org.scala-lang:scala-library:jar:2.11.8:compile [INFO] | +- com.typesafe:config:jar:1.3.3:compile [INFO] | \- org.scala-lang.modules:scala-java8-compat_2.11:jar:0.7.0:compile [INFO] +- org.apache.flink:flink-sql-client_2.11:jar:1.9.1:compile [INFO] | +- org.apache.flink:flink-clients_2.11:jar:1.9.1:compile [INFO] | | \- org.apache.flink:flink-optimizer_2.11:jar:1.9.1:compile [INFO] | +- org.apache.flink:flink-streaming-scala_2.11:jar:1.9.1:compile [INFO] | +- log4j:log4j:jar:1.2.17:compile [INFO] | \- org.apache.flink:flink-shaded-jackson:jar:2.9.8-7.0:compile [INFO] +- org.apache.flink:flink-json:jar:1.9.1:compile [INFO] +- org.apache.flink:flink-csv:jar:1.9.1:compile [INFO] +- org.apache.flink:flink-hbase_2.11:jar:1.9.1:compile [INFO] +- org.apache.hbase:hbase-server:jar:2.2.1:compile [INFO] | +- org.apache.hbase.thirdparty:hbase-shaded-protobuf:jar:2.2.1:compile [INFO] | +- org.apache.hbase.thirdparty:hbase-shaded-netty:jar:2.2.1:compile [INFO] | +- org.apache.hbase.thirdparty:hbase-shaded-miscellaneous:jar:2.2.1:compile [INFO] | | \- com.google.errorprone:error_prone_annotations:jar:2.3.3:compile [INFO] | +- org.apache.hbase:hbase-common:jar:2.2.1:compile [INFO] | | \- com.github.stephenc.findbugs:findbugs-annotations:jar:1.3.9-1:compile [INFO] | +- org.apache.hbase:hbase-http:jar:2.2.1:compile [INFO] | | +- org.eclipse.jetty:jetty-util:jar:9.3.27.v20190418:compile [INFO] | | +- org.eclipse.jetty:jetty-util-ajax:jar:9.3.27.v20190418:compile [INFO] | | +- org.eclipse.jetty:jetty-http:jar:9.3.27.v20190418:compile [INFO] | | +- org.eclipse.jetty:jetty-security:jar:9.3.27.v20190418:compile [INFO] | | +- org.glassfish.jersey.core:jersey-server:jar:2.25.1:compile [INFO] | | | +- org.glassfish.jersey.core:jersey-common:jar:2.25.1:compile [INFO] | | | | +- org.glassfish.jersey.bundles.repackaged:jersey-guava:jar:2.25.1:compile [INFO] | | | | \- org.glassfish.hk2:osgi-resource-locator:jar:1.0.1:compile [INFO] | | | +- org.glassfish.jersey.core:jersey-client:jar:2.25.1:compile [INFO] | | | +- org.glassfish.jersey.media:jersey-media-jaxb:jar:2.25.1:compile [INFO] | | | +- javax.annotation:javax.annotation-api:jar:1.2:compile [INFO] | | | +- org.glassfish.hk2:hk2-api:jar:2.5.0-b32:compile [INFO] | | | | +- org.glassfish.hk2:hk2-utils:jar:2.5.0-b32:compile [INFO] | | | | \- org.glassfish.hk2.external:aopalliance-repackaged:jar:2.5.0-b32:compile [INFO] | | | +- org.glassfish.hk2.external:javax.inject:jar:2.5.0-b32:compile [INFO] | | | \- org.glassfish.hk2:hk2-locator:jar:2.5.0-b32:compile [INFO] | | +- org.glassfish.jersey.containers:jersey-container-servlet-core:jar:2.25.1:compile [INFO] | | \- javax.ws.rs:javax.ws.rs-api:jar:2.0.1:compile [INFO] | +- org.apache.hbase:hbase-protocol:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-protocol-shaded:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-procedure:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-client:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-zookeeper:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-replication:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-metrics-api:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-metrics:jar:2.2.1:compile [INFO] | +- commons-codec:commons-codec:jar:1.10:compile [INFO] | +- org.apache.hbase:hbase-hadoop-compat:jar:2.2.1:compile [INFO] | +- org.apache.hbase:hbase-hadoop2-compat:jar:2.2.1:compile [INFO] | +- org.eclipse.jetty:jetty-server:jar:9.3.27.v20190418:compile [INFO] | | \- org.eclipse.jetty:jetty-io:jar:9.3.27.v20190418:compile [INFO] | +- org.eclipse.jetty:jetty-servlet:jar:9.3.27.v20190418:compile [INFO] | +- org.eclipse.jetty:jetty-webapp:jar:9.3.27.v20190418:compile [INFO] | | \- org.eclipse.jetty:jetty-xml:jar:9.3.27.v20190418:compile [INFO] | +- org.glassfish.web:javax.servlet.jsp:jar:2.3.2:compile [INFO] | | \- org.glassfish:javax.el:jar:3.0.1-b11:compile (version selected from constraint [3.0.0,)) [INFO] | +- javax.servlet.jsp:javax.servlet.jsp-api:jar:2.3.1:compile [INFO] | +- io.dropwizard.metrics:metrics-core:jar:3.2.6:compile [INFO] | +- commons-io:commons-io:jar:2.5:compile [INFO] | +- org.apache.commons:commons-math3:jar:3.6.1:compile [INFO] | +- org.apache.zookeeper:zookeeper:jar:3.4.10:compile [INFO] | +- javax.servlet:javax.servlet-api:jar:3.1.0:compile [INFO] | +- org.apache.htrace:htrace-core4:jar:4.2.0-incubating:compile [INFO] | +- com.lmax:disruptor:jar:3.3.6:compile [INFO] | +- commons-logging:commons-logging:jar:1.2:compile [INFO] | +- org.apache.commons:commons-crypto:jar:1.0.0:compile [INFO] | +- org.apache.hadoop:hadoop-distcp:jar:2.8.5:compile [INFO] | \- org.apache.yetus:audience-annotations:jar:0.5.0:compile [INFO] +- com.google.protobuf:protobuf-java:jar:2.5.0:compile [INFO] +- mysql:mysql-connector-java:jar:8.0.18:compile [INFO] +- org.apache.flink:flink-connector-hive_2.11:jar:1.9.1:compile [INFO] +- org.apache.flink:flink-hadoop-compatibility_2.11:jar:1.9.1:compile [INFO] +- org.apache.flink:flink-shaded-hadoop-2-uber:jar:2.7.5-7.0:provided [INFO] +- org.apache.hive:hive-exec:jar:2.1.1:compile [INFO] | +- org.apache.hive:hive-ant:jar:2.1.1:compile [INFO] | | \- org.apache.velocity:velocity:jar:1.5:compile [INFO] | | \- oro:oro:jar:2.0.8:compile [INFO] | +- org.apache.hive:hive-llap-tez:jar:2.1.1:compile [INFO] | | +- org.apache.hive:hive-common:jar:2.1.1:compile [INFO] | | | +- org.apache.hive:hive-storage-api:jar:2.1.1:compile [INFO] | | | +- org.apache.hive:hive-orc:jar:2.1.1:compile [INFO] | | | | \- org.iq80.snappy:snappy:jar:0.2:compile [INFO] | | | +- org.eclipse.jetty.aggregate:jetty-all:jar:7.6.0.v20120127:compile [INFO] | | | | +- org.apache.geronimo.specs:geronimo-jta_1.1_spec:jar:1.1.1:compile [INFO] | | | | +- javax.mail:mail:jar:1.4.1:compile [INFO] | | | | +- javax.activation:activation:jar:1.1:compile [INFO] | | | | +- org.apache.geronimo.specs:geronimo-jaspic_1.0_spec:jar:1.0:compile [INFO] | | | | +- org.apache.geronimo.specs:geronimo-annotation_1.0_spec:jar:1.1.1:compile [INFO] | | | | \- asm:asm-commons:jar:3.1:compile [INFO] | | | | \- asm:asm-tree:jar:3.1:compile [INFO] | | | | \- asm:asm:jar:3.1:compile [INFO] | | | +- org.eclipse.jetty.orbit:javax.servlet:jar:3.0.0.v201112011016:compile [INFO] | | | +- joda-time:joda-time:jar:2.8.1:compile [INFO] | | | +- org.json:json:jar:20160810:compile [INFO] | | | +- io.dropwizard.metrics:metrics-jvm:jar:3.1.0:compile [INFO] | | | +- io.dropwizard.metrics:metrics-json:jar:3.1.0:compile [INFO] | | | \- com.github.joshelser:dropwizard-metrics-hadoop-metrics2-reporter:jar:0.1.2:compile [INFO] | | \- org.apache.hive:hive-llap-client:jar:2.1.1:compile [INFO] | | \- org.apache.hive:hive-llap-common:jar:2.1.1:compile [INFO] | | \- org.apache.hive:hive-serde:jar:2.1.1:compile [INFO] | | +- org.apache.hive:hive-service-rpc:jar:2.1.1:compile [INFO] | | | +- tomcat:jasper-compiler:jar:5.5.23:compile [INFO] | | | | +- javax.servlet:jsp-api:jar:2.0:compile [INFO] | | | | \- ant:ant:jar:1.6.5:compile [INFO] | | | +- tomcat:jasper-runtime:jar:5.5.23:compile [INFO] | | | | +- javax.servlet:servlet-api:jar:2.4:compile [INFO] | | | | \- commons-el:commons-el:jar:1.0:compile [INFO] | | | \- org.apache.thrift:libfb303:jar:0.9.3:compile [INFO] | | +- org.apache.avro:avro:jar:1.7.7:compile [INFO] | | | \- com.thoughtworks.paranamer:paranamer:jar:2.3:compile [INFO] | | +- net.sf.opencsv:opencsv:jar:2.3:compile [INFO] | | \- org.apache.parquet:parquet-hadoop-bundle:jar:1.8.1:compile [INFO] | +- org.apache.hive:hive-shims:jar:2.1.1:compile [INFO] | | +- org.apache.hive.shims:hive-shims-common:jar:2.1.1:compile [INFO] | | | \- org.apache.thrift:libthrift:jar:0.9.3:compile [INFO] | | +- org.apache.hive.shims:hive-shims-0.23:jar:2.1.1:runtime [INFO] | | | \- org.apache.hadoop:hadoop-yarn-server-resourcemanager:jar:2.6.1:runtime [INFO] | | | +- org.apache.hadoop:hadoop-annotations:jar:2.6.1:runtime [INFO] | | | +- com.google.inject.extensions:guice-servlet:jar:3.0:runtime [INFO] | | | +- com.google.inject:guice:jar:3.0:runtime [INFO] | | | | +- javax.inject:javax.inject:jar:1:runtime [INFO] | | | | \- aopalliance:aopalliance:jar:1.0:runtime [INFO] | | | +- com.sun.jersey:jersey-json:jar:1.9:runtime [INFO] | | | | +- com.sun.xml.bind:jaxb-impl:jar:2.2.3-1:runtime [INFO] | | | | +- org.codehaus.jackson:jackson-core-asl:jar:1.8.3:compile [INFO] | | | | +- org.codehaus.jackson:jackson-mapper-asl:jar:1.8.3:compile [INFO] | | | | +- org.codehaus.jackson:jackson-jaxrs:jar:1.8.3:runtime [INFO] | | | | \- org.codehaus.jackson:jackson-xc:jar:1.8.3:runtime [INFO] | | | +- com.sun.jersey.contribs:jersey-guice:jar:1.9:runtime [INFO] | | | | \- com.sun.jersey:jersey-server:jar:1.9:runtime [INFO] | | | +- org.apache.hadoop:hadoop-yarn-common:jar:2.6.1:runtime [INFO] | | | +- org.apache.hadoop:hadoop-yarn-api:jar:2.6.1:runtime [INFO] | | | +- javax.xml.bind:jaxb-api:jar:2.2.2:runtime [INFO] | | | | \- javax.xml.stream:stax-api:jar:1.0-2:runtime [INFO] | | | +- org.codehaus.jettison:jettison:jar:1.1:runtime [INFO] | | | +- com.sun.jersey:jersey-core:jar:1.9:runtime [INFO] | | | +- com.sun.jersey:jersey-client:jar:1.9:runtime [INFO] | | | +- org.mortbay.jetty:jetty-util:jar:6.1.26:runtime [INFO] | | | +- org.apache.hadoop:hadoop-yarn-server-common:jar:2.6.1:runtime [INFO] | | | | \- org.fusesource.leveldbjni:leveldbjni-all:jar:1.8:runtime [INFO] | | | +- org.apache.hadoop:hadoop-yarn-server-applicationhistoryservice:jar:2.6.1:runtime [INFO] | | | \- org.apache.hadoop:hadoop-yarn-server-web-proxy:jar:2.6.1:runtime [INFO] | | | \- org.mortbay.jetty:jetty:jar:6.1.26:runtime [INFO] | | \- org.apache.hive.shims:hive-shims-scheduler:jar:2.1.1:runtime [INFO] | +- commons-httpclient:commons-httpclient:jar:3.0.1:compile [INFO] | +- org.antlr:antlr-runtime:jar:3.4:compile [INFO] | | +- org.antlr:stringtemplate:jar:3.2.1:compile [INFO] | | \- antlr:antlr:jar:2.7.7:compile [INFO] | +- org.antlr:ST4:jar:4.0.4:compile [INFO] | +- org.apache.ant:ant:jar:1.9.1:compile [INFO] | | \- org.apache.ant:ant-launcher:jar:1.9.1:compile [INFO] | +- org.apache.commons:commons-compress:jar:1.10:compile [INFO] | +- org.apache.ivy:ivy:jar:2.4.0:compile [INFO] | +- org.apache.curator:curator-framework:jar:2.6.0:compile [INFO] | | \- org.apache.curator:curator-client:jar:2.6.0:compile [INFO] | +- org.apache.curator:apache-curator:pom:2.6.0:compile [INFO] | +- org.codehaus.groovy:groovy-all:jar:2.4.4:compile [INFO] | +- org.apache.calcite:calcite-core:jar:1.6.0:compile [INFO] | | +- org.apache.calcite:calcite-linq4j:jar:1.6.0:compile [INFO] | | +- commons-dbcp:commons-dbcp:jar:1.4:compile [INFO] | | | \- commons-pool:commons-pool:jar:1.5.4:compile [INFO] | | +- net.hydromatic:aggdesigner-algorithm:jar:6.0:compile [INFO] | | \- org.codehaus.janino:commons-compiler:jar:2.7.6:compile [INFO] | +- org.apache.calcite:calcite-avatica:jar:1.6.0:compile [INFO] | +- stax:stax-api:jar:1.0.1:compile [INFO] | \- jline:jline:jar:2.12:compile [INFO] +- org.datanucleus:datanucleus-core:jar:4.1.6:compile [INFO] +- org.datanucleus:datanucleus-api-jdo:jar:4.2.4:compile [INFO] +- org.datanucleus:javax.jdo:jar:3.2.0-m3:compile [INFO] | \- javax.transaction:transaction-api:jar:1.1:compile [INFO] +- org.datanucleus:datanucleus-rdbms:jar:4.1.9:compile [INFO] +- hadoop-lzo:hadoop-lzo:jar:0.4.14:compile [INFO] \- org.apache.flink:flink-runtime-web_2.11:jar:1.9.1:provided [INFO] +- org.apache.flink:flink-runtime_2.11:jar:1.9.1:compile [INFO] | +- org.apache.flink:flink-queryable-state-client-java:jar:1.9.1:compile [INFO] | +- org.apache.flink:flink-hadoop-fs:jar:1.9.1:compile [INFO] | +- org.apache.flink:flink-shaded-asm-6:jar:6.2.1-7.0:compile [INFO] | +- com.typesafe.akka:akka-stream_2.11:jar:2.5.21:compile [INFO] | | +- org.reactivestreams:reactive-streams:jar:1.0.2:compile [INFO] | | \- com.typesafe:ssl-config-core_2.11:jar:0.3.7:compile [INFO] | +- com.typesafe.akka:akka-protobuf_2.11:jar:2.5.21:compile [INFO] | +- com.typesafe.akka:akka-slf4j_2.11:jar:2.4.11:compile [INFO] | +- org.clapper:grizzled-slf4j_2.11:jar:1.3.2:compile [INFO] | +- com.github.scopt:scopt_2.11:jar:3.5.0:compile [INFO] | +- org.xerial.snappy:snappy-java:jar:1.1.4:compile [INFO] | \- com.twitter:chill_2.11:jar:0.7.6:compile [INFO] | \- com.twitter:chill-java:jar:0.7.6:compile [INFO] +- org.apache.flink:flink-shaded-netty:jar:4.1.32.Final-7.0:compile [INFO] +- org.apache.flink:flink-shaded-guava:jar:18.0-7.0:compile [INFO] \- org.javassist:javassist:jar:3.19.0-GA:compile [INFO] ———————————————————————————————————— 日志： 2020-02-28 17:17:07,890 INFO org.apache.hadoop.security.UserGroupInformation - Login successful for user ***/dev@***.COM using keytab file /home/***/key.keytab 上面这条是flink日志打印的，从这条日志可以看出 kerberos认证是通过的，能够正常登录，但还是报了以下异常： 2020-02-28 17:17:08,658 INFO org.apache.hadoop.hive.metastore.ObjectStore - Setting MetaStore object pin classes with hive.metastore.cache.pinobjtypes="Table,Database,Type,FieldSchema,Order" 2020-02-28 17:17:09,280 INFO org.apache.hadoop.hive.metastore.MetaStoreDirectSql - Using direct SQL, underlying DB is MYSQL 2020-02-28 17:17:09,283 INFO org.apache.hadoop.hive.metastore.ObjectStore - Initialized ObjectStore 2020-02-28 17:17:09,450 INFO org.apache.hadoop.hive.metastore.HiveMetaStore - Added admin role in metastore 2020-02-28 17:17:09,452 INFO org.apache.hadoop.hive.metastore.HiveMetaStore - Added public role in metastore 2020-02-28 17:17:09,474 INFO org.apache.hadoop.hive.metastore.HiveMetaStore - No user is added in admin role, since config is empty 2020-02-28 17:17:09,634 INFO org.apache.flink.table.catalog.hive.HiveCatalog - Connected to Hive metastore 2020-02-28 17:17:09,635 INFO org.apache.hadoop.hive.metastore.HiveMetaStore - 0: get_database: *** 2020-02-28 17:17:09,637 INFO org.apache.hadoop.hive.metastore.HiveMetaStore.audit - ugi=*** ip=unknown-ip-addr cmd=get_database: *** 2020-02-28 17:17:09,658 INFO org.apache.hadoop.hive.ql.metadata.HiveUtils - Adding metastore authorization provider: org.apache.hadoop.hive.ql.security.authorization.StorageBasedAuthorizationProvider 2020-02-28 17:17:10,166 WARN org.apache.hadoop.hdfs.shortcircuit.DomainSocketFactory - The short-circuit local reads feature cannot be used because libhadoop cannot be loaded. 2020-02-28 17:17:10,391 WARN org.apache.hadoop.ipc.Client - Exception encountered while connecting to the server : org.apache.hadoop.security.AccessControlException: Client cannot authenticate via:[TOKEN, KERBEROS] 2020-02-28 17:17:10,397 WARN org.apache.hadoop.ipc.Client - Exception encountered while connecting to the server : org.apache.hadoop.security.AccessControlException: Client cannot authenticate via:[TOKEN, KERBEROS] 2020-02-28 17:17:10,398 INFO org.apache.hadoop.io.retry.RetryInvocationHandler - Exception while invoking getFileInfo of class ClientNamenodeProtocolTranslatorPB over ******.org/***.***.***.***:8020 after 1 fail over attempts. Trying to fail over immediately. java.io.IOException: Failed on local exception: java.io.IOException: org.apache.hadoop.security.AccessControlException: Client cannot authenticate via:[TOKEN, KERBEROS]; Host Details : local host is: "***.***.***.org/***.***.***.***"; destination host is: "******.org":8020; at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:776) at org.apache.hadoop.ipc.Client.call(Client.java:1480) at org.apache.hadoop.ipc.Client.call(Client.java:1413) at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:229) at com.sun.proxy.$Proxy41.getFileInfo(Unknown Source) at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB. getFileInfo(ClientNamenodeProtocolTranslatorPB.java:776) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:191) at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:102) at com.sun.proxy.$Proxy42.getFileInfo(Unknown Source) at org.apache.hadoop.hdfs.DFSClient.getFileInfo(DFSClient.java:2117) at org.apache.hadoop.hdfs.DistributedFileSystem$22.doCall(DistributedFileSystem.java:1305) at org.apache.hadoop.hdfs.DistributedFileSystem$22.doCall(DistributedFileSystem.java:1301) at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) at org.apache.hadoop.hdfs.DistributedFileSystem.getFileStatus(DistributedFileSystem.java:1317) at org.apache.hadoop.hive.common.FileUtils.getFileStatusOrNull(FileUtils.java:770) at org.apache.hadoop.hive.ql.security.authorization.StorageBasedAuthorizationProvider.checkPermissions(StorageBasedAuthorizationProvider.java:368) at org.apache.hadoop.hive.ql.security.authorization.StorageBasedAuthorizationProvider.authorize(StorageBasedAuthorizationProvider.java:343) at org.apache.hadoop.hive.ql.security.authorization.StorageBasedAuthorizationProvider.authorize(StorageBasedAuthorizationProvider.java:152) at org.apache.hadoop.hive.ql.security.authorization.AuthorizationPreEventListener.authorizeReadDatabase(AuthorizationPreEventListener.java:204) at org.apache.hadoop.hive.ql.security.authorization.AuthorizationPreEventListener.onEvent(AuthorizationPreEventListener.java:152) at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.firePreEvent(HiveMetaStore.java:2153) at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.get_database(HiveMetaStore.java:932) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.hadoop.hive.metastore.RetryingHMSHandler.invokeInternal(RetryingHMSHandler.java:140) at org.apache.hadoop.hive.metastore.RetryingHMSHandler.invoke(RetryingHMSHandler.java:99) at com.sun.proxy.$Proxy35.get_database(Unknown Source) at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1280) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:150) at com.sun.proxy.$Proxy36.getDatabase(Unknown Source) at org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper. getDatabase(HiveMetastoreClientWrapper.java:102) at org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:347) at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:244) at org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:153) at org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:170) ……在这段省略的代码里做了UserGroupInformation.loginUserFromKeytab(principal,keytab);并成功通过认证 at this is my code.main(MyMainClass.java:24) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:576) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:438) at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83) at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:80) at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:122) at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:227) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:205) at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754) at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083) Caused by: java.io.IOException: org.apache.hadoop.security.AccessControlException: Client cannot authenticate via:[TOKEN, KERBEROS] at org.apache.hadoop.ipc.Client$Connection$1.run(Client.java:688) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754) at org.apache.hadoop.ipc.Client$Connection.handleSaslConnectionFailure(Client.java:651) at org.apache.hadoop.ipc.Client$Connection.setupIOstreams(Client.java:738) at org.apache.hadoop.ipc.Client$Connection.access$2900(Client.java:376) at org.apache.hadoop.ipc.Client.getConnection(Client.java:1529) at org.apache.hadoop.ipc.Client.call(Client.java:1452) ... 67 more Caused by: org.apache.hadoop.security.AccessControlException: Client cannot authenticate via:[TOKEN, KERBEROS] at org.apache.hadoop.security.SaslRpcClient.selectSaslClient(SaslRpcClient.java:172) at org.apache.hadoop.security.SaslRpcClient.saslConnect(SaslRpcClient.java:396) at org.apache.hadoop.ipc.Client$Connection.setupSaslConnection(Client.java:561) at org.apache.hadoop.ipc.Client$Connection.access$1900(Client.java:376) at org.apache.hadoop.ipc.Client$Connection$2.run(Client.java:730) at org.apache.hadoop.ipc.Client$Connection$2.run(Client.java:726) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754) at org.apache.hadoop.ipc.Client$Connection.setupIOstreams(Client.java:726) ... 70 more 目前诊断看起来像是jar被污染导致。麻烦请指点一二。谢谢！ 叶贤勋 yxx_c...@163.com <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E5%8F%B6%E8%B4%A4%E5%8B%8B&uid=yxx_cmhd%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fsmd968c697b9ad8ea62cb19d8a7846a999.jpg&items=%5B%22yxx_cmhd%40163.com%22%5D> 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制 在2020年02月28日 15:16，Rui Li<li...@apache.org> <li...@apache.org> 写道： Hi 叶贤勋, 我手头上没有kerberos的环境，从TokenCache的代码（2.7.5版本）看起来，这个异常可能是因为没有正确拿到RM的地址或者principal。请检查一下下面这几个配置： mapreduce.framework.name yarn.resourcemanager.address yarn.resourcemanager.principal 以及你的flink的作业是否能读到这些配置 On Fri, Feb 28, 2020 at 11:10 AM Kurt Young <ykt...@gmail.com> wrote: cc @li...@apache.org <li...@apache.org> Best, Kurt On Thu, Feb 13, 2020 at 10:22 AM 叶贤勋 <yxx_c...@163.com> wrote: Hi 大家好： 在做hive2.1.1 source带Kerberos认证有个异常请教下大家。 flink 版本1.9 hive 版本2.1.1，实现了HiveShimV211。 代码： public class HiveCatalogTest { private static final Logger LOG = LoggerFactory.getLogger(HiveCatalogTest.class); private String hiveConfDir = "/Users/yexianxun/dev/env/test-hive"; // a local path private TableEnvironment tableEnv; private HiveCatalog hive; private String hiveName; private String hiveDB; private String version; @Before public void before() { EnvironmentSettings settings = EnvironmentSettings.newInstance() .useBlinkPlanner() .inBatchMode() .build(); tableEnv = TableEnvironment.create(settings); hiveName = "myhive"; hiveDB = "sloth"; version = "2.1.1"; } @Test public void testCatalogQuerySink() throws Exception { hive = new HiveCatalog(hiveName, hiveDB, hiveConfDir, version); System.setProperty("java.security.krb5.conf", hiveConfDir + "/krb5.conf"); tableEnv.getConfig().getConfiguration().setString("stream_mode", "false"); tableEnv.registerCatalog(hiveName, hive); tableEnv.useCatalog(hiveName); String query = "select * from " + hiveName + "." + hiveDB + ".testtbl2 where id = 20200202"; Table table = tableEnv.sqlQuery(query); String newTableName = "testtbl2_1"; table.insertInto(hiveName, hiveDB, newTableName); tableEnv.execute("test"); } } HiveMetastoreClientFactory: public static HiveMetastoreClientWrapper create(HiveConf hiveConf, String hiveVersion) { Preconditions.checkNotNull(hiveVersion, "Hive version cannot be null"); if (System.getProperty("java.security.krb5.conf") != null) { if (System.getProperty("had_set_kerberos") == null) { String principal = "sloth/d...@bdms.163.com"; String keytab = "/Users/yexianxun/dev/env/mammut-test-hive/sloth.keytab"; try { sun.security.krb5.Config.refresh(); UserGroupInformation.setConfiguration(hiveConf); UserGroupInformation.loginUserFromKeytab(principal, keytab); System.setProperty("had_set_kerberos", "true"); } catch (Exception e) { LOG.error("", e); } } } return new HiveMetastoreClientWrapper(hiveConf, hiveVersion); } HiveCatalog: private static HiveConf createHiveConf(@Nullable String hiveConfDir) { LOG.info("Setting hive conf dir as {}", hiveConfDir); try { HiveConf.setHiveSiteLocation( hiveConfDir == null ? null : Paths.get(hiveConfDir, "hive-site.xml").toUri().toURL()); } catch (MalformedURLException e) { throw new CatalogException( String.format("Failed to get hive-site.xml from %s", hiveConfDir), e); } // create HiveConf from hadoop configuration HiveConf hiveConf = new HiveConf(HadoopUtils.getHadoopConfiguration(new org.apache.flink.configuration.Configuration()), HiveConf.class); try { hiveConf.addResource(Paths.get(hiveConfDir, "hdfs-site.xml").toUri().toURL()); hiveConf.addResource(Paths.get(hiveConfDir, "core-site.xml").toUri().toURL()); } catch (MalformedURLException e) { throw new CatalogException(String.format("Failed to get hdfs|core-site.xml from %s", hiveConfDir), e); } return hiveConf; } 在执行testCatalogQuerySink方法报以下错误： org.apache.flink.runtime.client.JobExecutionException: Could not retrieve JobResult. at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:622) at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:117) at org.apache.flink.table.planner.delegation.BatchExecutor.execute(BatchExecutor.java:55) at org.apache.flink.table.api.internal.TableEnvironmentImpl.execute(TableEnvironmentImpl.java:410) at api.HiveCatalogTest.testCatalogQuerySink(HiveCatalogMumTest.java:234) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57) at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) at org.junit.runners.ParentRunner.run(ParentRunner.java:363) at org.junit.runner.JUnitCore.run(JUnitCore.java:137) at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47) at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242) at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit job. at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$internalSubmitJob$2(Dispatcher.java:333) at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822) at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797) at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: java.lang.RuntimeException: org.apache.flink.runtime.client.JobExecutionException: Could not set up JobManager at org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:36) at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ... 6 more Caused by: org.apache.flink.runtime.client.JobExecutionException: Could not set up JobManager at org.apache.flink.runtime.jobmaster.JobManagerRunner.<init>(JobManagerRunner.java:152) at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:83) at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:375) at org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:34) ... 7 more Caused by: org.apache.flink.runtime.JobException: Creating the input splits caused an error: Can't get Master Kerberos principal for use as renewer at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:270) at org.apache.flink.runtime.executiongraph.ExecutionGraph.attachJobGraph(ExecutionGraph.java:907) at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:230) at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:106) at org.apache.flink.runtime.scheduler.LegacyScheduler.createExecutionGraph(LegacyScheduler.java:207) at org.apache.flink.runtime.scheduler.LegacyScheduler.createAndRestoreExecutionGraph(LegacyScheduler.java:184) at org.apache.flink.runtime.scheduler.LegacyScheduler.<init>(LegacyScheduler.java:176) at org.apache.flink.runtime.scheduler.LegacySchedulerFactory.createInstance(LegacySchedulerFactory.java:70) at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:278) at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:266) at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:98) at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:40) at org.apache.flink.runtime.jobmaster.JobManagerRunner.<init>(JobManagerRunner.java:146) ... 10 more Caused by: java.io.IOException: Can't get Master Kerberos principal for use as renewer at org.apache.hadoop.mapreduce.security.TokenCache.obtainTokensForNamenodesInternal(TokenCache.java:116) at org.apache.hadoop.mapreduce.security.TokenCache.obtainTokensForNamenodesInternal(TokenCache.java:100) at org.apache.hadoop.mapreduce.security.TokenCache.obtainTokensForNamenodes(TokenCache.java:80) at org.apache.hadoop.mapred.FileInputFormat.listStatus(FileInputFormat.java:206) at org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:315) at org.apache.flink.connectors.hive.HiveTableInputFormat.createInputSplits(HiveTableInputFormat.java:159) at org.apache.flink.connectors.hive.HiveTableInputFormat.createInputSplits(HiveTableInputFormat.java:63) at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:256) ... 22 more 测试sink的方法是能够正常插入数据，但是在hive source时报这个错误，感觉是获取deleg token时返回空导致的。不知道具体应该怎么解决 | | 叶贤勋 | | yxx_c...@163.com | 签名由网易邮箱大师定制
