У меня возникает ошибка ниже при попытке установить соединение HiveStreamingConnection с использованием приведенного ниже кода в среде с поддержкой Kerberos.
HiveConf hiveConf = new HiveConf ((Конфигурация) config.getConf (), HiveConf.class);
conn = HiveStreamingConnection.newBuilder (). WithDatabase (dbName) .withTable (tblName) .withHiveConf (hiveConf) .withRecordWriter (writer) .connect ();
Исключениениже:
2019-09-30 11: 12: 30.100 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ИНФОРМАЦИЯ streaming.HiveStreamingConnection: Создание клиента метастазирования для потокового соединения 2019-09-30 11: 12: 30.203 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ИНФОРМАЦИЯ metastore.HiveMetaStoreClient: Попытка подключения к метастару с использованием URI: //irrhdp651.informatica.com: 9083 2019-09-30 11:12:30.241 INFO: 19/09/30 11:12:30 INFO metastore.HiveMetaStoreClient: Открыто подключение к metastore, текущие подключения: 1 2019-09-30 11: 12: 30.312 INFO: 19/09/30 11:12:30WARN metastore.HiveMetaStoreClient: set_ugi () нетуспешное, вероятная причина: новый клиент говорит со старым сервером. Продолжая без этого. 2019-09-30 11: 12: 30.313 ИНФОРМАЦИЯ: org.apache.thrift.transport.TTransportException 2019-09-30 11: 12: 30.313 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TIOStreamTransport.read (TIOStreamTransport.java:132) 2019-09-30 11: 12: 30.313 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TTransport.readAll (TTransport.java:86) 2019-09-30 11: 12: 30.313 ИНФОРМАЦИЯ: в org.apache. thrift.protocol.TBinaryProtocol.readStringBody (TBinaryProtocol.java:380) 2019-09-30 11: 12: 30.314 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin (TBinaryProtocol.java:230) 2019-09-3011: 12: 30.317 ИНФОРМАЦИЯ: в org.apache.thrift.TServiceClient.receiveBase (TServiceClient.java:77) 2019-09-30 11: 12: 30.318 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$ Client.recv_set_ugi (ThriftHiveMetastore.java:4998) 2019-09-30 11: 12: 30.318 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.set_ugi (ThriftHiveMetastore.java-4984)09-30 11: 12: 30.318 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open (ПриветveMetaStoreClient.java:566) 2019-09-30 11: 12: 30.318 ИНФОРМАЦИЯ: at org.apache.hadoop.hive.metastore.HiveMetaStoreClient. (HiveMetaStoreClient.java:225) 2019-09-30 11: 12: 30.319 ИНФО:at sun.reflect.NativeConstructorAccessorImpl.newInstance0 (собственный метод) 2019-09-30 11: 12: 30.319 INFO: at sun.reflect.NativeConstructorAccessorImpl.newInstance (NativeConstructorAccessorImpl.java:62) 2019-09-30 11: 12: 30.3: at sun.reflect.DelegatingConstructorAccessorImpl.newInstance (DelegatingConstructorAccessorImpl.java:45) 2019-09-30 11: 12: 30.319 ИНФОРМАЦИЯ: в java.lang.reflect.Constructor.newInstance (Constructor.java:423) 2019-09-3011: 12: 30.319 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.utils.JavaUtils.newInstance (JavaUtils.java:84) 2019-09-30 11: 12: 30.320 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore. 11: 12: 30.320 INFO: at org.apache.hadoop.hive.metastore.RetringMetaStoreClient.getProxy (RetriedMetaStoreClient.java:104) 2019-09-30 11: 12: 30.320 ИНФОРМАЦИЯ: at org.apache.hadoop.hive.metastore.HiveClientCache.oniteHiveClientCache.java:89) 2019-09-30 11: 12: 30.320 ИНФОРМАЦИЯ: at org.apache.hadoop.hive.metastore.HiveMetaStoreUtils.getHiveMetastoreClient (HiveMetaStoreUtils.java:230) 2019-09-30 11: 12: 30.321 INFO: at org.apache.hive.streaming.HiveStreamingConnection.getMetaStoreClient (HiveStreamingConnection.java:574) 2019-09-30 11: 12: 30.321 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.j)2019-09-30 11: 12: 30.321 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:118) 2019-09-30 11: 12: 30.321 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection $ Builder.connect (HiveStreamingConnection.java:332) 2019-09-30 11: 12: 30.321 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.io.impl.formatter.IHiveStreamingOutputFormatImpl.init (Impl.init. Java: 50) 2019-09-30 11: 12: 30.322 ИНФОРМАЦИЯ: на com.informatica.platform.dtm.executor.hadoop.security.IHadoopSecurityHandlerFactory $ 3.run (IHadoopSecurityHandlerFactory.java:55) 2019-09-30 11:12: 30.322 ИНФОРМАЦИЯ: в java.security.AccessController.doPrivileged (собственный метод) 2019-09-30 11: 12: 30.322 ИНФО: в javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-3011: 12: 30.322 ИНФОРМАЦИЯ: в org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1730) 2019-09-30 11: 12: 30.322 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.impl.AbstractIUserGroupInformationImpl.doAs(AbstractIUserGroupInformationImpl.java:122) 2019-09-30 11: 12: 30.323 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.security.HadoopSecurityUtil.doAs (HadoopSecurityUtil.java:329) 2019-09-30 11: 12: 30.323 INFO: на com.informatica.extensions.hivehdfssdk.wrt.HiveHdfsWrtPartitionDriver.init (HiveHdfsWrtPartitionDriver.java:299) 2019-09-30 11: 12: 30.323 INFO: 19/09/30 11:12:30 INFOmetastore.HiveMetaStoreClient: подключен к metastore. 2019-09-30 11: 12: 30.323 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ИНФОРМАЦИЯ metastore.RetringMetaStoreClient: RetryMetaStoreClient proxy = класс org.apache.hadoop.hive.metastore.HiveMetaStoreClient ugi = impUser1 (автор: TOKEN)повторные попытки = 1 задержка = 1 срок службы = 0 2019-09-30 11: 12: 30.486 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ИНФОРМАЦИЯ о потоковой передаче.HiveStreamingConnection: создание клиента метастазирования для потоковой-подключения-сердцебиения 2019-09-3011: 12: 30.487 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ИНФОРМАЦИЯ metastore.HiveMetaStoreClient: Попытка подключения к metastore с использованием URI: //irrhdp651.informatica.com: 9083 2019-09-30 11: 12: 30.488ИНФОРМАЦИЯ: 19/09/30 11:12:30 ИНФОРМАЦИЯ metastore.HiveMetaStoreClient: Открыто соединение с metastore, текущие соединения: 2 2019-09-30 11: 12: 30.508 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ПРЕДУПРЕЖДЕНИЕmetastore.HiveMetaStoreClient: set_ugi () не успешно, вероятная причина: новый клиент общается со старым сервером. Продолжая без этого. 2019-09-30 11: 12: 30.508 ИНФОРМАЦИЯ: org.apache.thrift.transport.TTransportException 2019-09-30 11: 12: 30.509 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TIOStreamTransport.read (TIOStreamTransport.java:132) 2019-09-30 11: 12: 30.509 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TTransport.readAll (TTransport.java:86) 2019-09-30 11: 12: 30.509 ИНФОРМАЦИЯ: в org.apache. thrift.protocol.TBinaryProtocol.readStringBody (TBinaryProtocol.java:380) 2019-09-30 11: 12: 30.510 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin (TBinaryProtocol.java:230) 2019-09-3011: 12: 30.510 ИНФОРМАЦИЯ: в org.apache.thrift.TServiceClient.receiveBase (TServiceClient.java:77) 2019-09-30 11: 12: 30.510 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$ Client.recv_set_ugi (ThriftHiveMetastore.java:4998) 2019-09-30 11: 12: 30.510 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.set_ugi (ThriftHiveMetastore.java-4984)09-30 11: 12: 30.510 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open (ПриветveMetaStoreClient.java:566) 2019-09-30 11: 12: 30.510 ИНФОРМАЦИЯ: at org.apache.hadoop.hive.metastore.HiveMetaStoreClient. (HiveMetaStoreClient.java:225) 2019-09-30 11: 12: 30.511 ИНФО:at sun.reflect.NativeConstructorAccessorImpl.newInstance0 (собственный метод) 2019-09-30 11: 12: 30.511 ИНФО: at sun.reflect.NativeConstructorAccessorImpl.newInstance (NativeConstructorAccessorImpl.java:62) 2019-09-30 11: 12.5: 30: at sun.reflect.DelegatingConstructorAccessorImpl.newInstance (DelegatingConstructorAccessorImpl.java:45)2019-09-30 11: 12: 30.511 ИНФОРМАЦИЯ: на java.lang.reflect.Constructor.newInstance (Constructor.java:423) 2019-09-30 11: 12: 30.511 ИНФОРМАЦИЯ: на org.apache.hadoop.hive. metastore.utils.JavaUtils.newInstance (JavaUtils.java:84) 2019-09-30 11: 12: 30.511 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient. (RetringMetaStoreClient.java:95) 2019-09-30 11: 12: 30.512 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient.getProxy (RetringMetaStoreClient.java:148) 2019-09-30 11: 12: 30.512 ИНФОРМАЦИЯ: в org.apache.hadoop.hive. metastore.RetringMetaStoreClient.getProxy (RetedingMetaStoreClient.java:104) 2019-09-30 11: 12: 30.512 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveClientCache.getNonCachedHiveMetastoreClient (HiveCaventClient 201:30)11: 12: 30.512 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreUtils.getHiveMetastoreClient (HiveMetaStoreUtils.java:230) 2019-09-30 11: 12: 30.512 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStream.getMetaStoreClient (HiveStreamingConnection.java:574) 2019-09-30 11: 12: 30.513 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:201) 2019-09-30 11: 12: 30.513 ИНФОРМАЦИЯ: в организации.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:118) 2019-09-30 11: 12: 30.513 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection $ Builder.connect (HiveStreamingConnection.java:332) 2019-09-30 11: 12: 30.513 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.io.impl.formatter.IHiveStreamingOutputFormatImpl.init (IHiveStreamingOutputFormatImpl.java:50) 2019-09-30 11: 12: 30.513ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.security.IHadoopSecurityHandlerFactory $ 3.run (IHadoopSecurityHandlerFactory.java:55) 2019-09-30 11: 12: 30.513 ИНФОРМАЦИЯ: в java.security.AccessControlled.PurityМетод) 2019-09-30 11: 12: 30.514 ИНФОРМАЦИЯ: в javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-30 11: 12: 30.514 ИНФОРМАЦИЯ: в org.apache.hadoop. security.UserGroupInformation.doAs (UserGroupInformation.java: 1730) 2019-09-30 11: 12: 30.514 ИНФОРМАЦИЯ: at com.informatica.platform.dtm.executor.hadoop.impl.AbstractIUserGroupInformationImpl.doAs (AbstractIUserGroupInformationImpl.java:122) 2019-09-30 11:12:30.514 ИНФОРМАЦИЯ: на com.informatica.platform.dtm.executor.hadoop.security.HadoopSecurityUtil.doAs (HadoopSecurityUtil.java:329) 2019-09-30 11: 12: 30.514 ИНФОРМАЦИЯ: на com.informatica.extensions.hivehdfssdk.wt.HiveHdfsWrtPartitionDriver.init (HiveHdfsWrtPartitionDriver.java:299) 2019-09-30 11: 12: 30.515 INFO: 19/09/30 11:12:30 INFO metastore.HiveMetaStoreClient: подключено к metastore. 2019-09-30 11: 12: 30.515 ИНФОРМАЦИЯ: 19.09.30 11:12:30 ИНФОРМАЦИЯ metastore.RetringMetaStoreClient: RetryMetaStoreClient proxy = класс org.apache.hadoop.hive.metastore.HiveMetaStoreClient ugi = impUser1 (автор: TOKEN)повторные попытки = 1 задержка = 1 срок службы = 0 2019-09-30 11: 12: 30.549 ИНФОРМАЦИЯ: 19/09/30 11:12:30 ПРЕДУПРЕЖДЕНИЕ metastore.RetringMetaStoreClient: MetaStoreClient потерял соединение. Попытка переподключения (1 из 1) через 1 с. getTable 2019-09-30 11: 12: 30.549 ИНФОРМАЦИЯ: org.apache.thrift.transport.TTransportException 2019-09-30 11: 12: 30.549 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TIOStreamTransport.read (TIOStreamTransport.java: 132) 2019-09-30 11: 12: 30.550 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TTransport.readAll (TTransport.java:86) 2019-09-30 11: 12: 30.550 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readAll (TBinaryProtocol.java:429) 2019-09-30 11: 12: 30.550 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readI32 (TBinaryProtocol.java:318) 2019-09-30 11: 12: 30.552 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin (TBinaryProtocol.java:219) 2019-09-30 11: 12: 30.552 ИНФОРМАЦИЯ: в org.apache.thrift.TServiceClient.receiveBase (TServiceClient.java:77)2019-09-30 11: 12: 30.552 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.recv_get_table_req (ThriftHiveMetastore.java:2133) 2019-09-30 11: 12: 30.552 ИНФОРМАЦИЯ: вorg.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.get_table_req (ThriftHiveMetastore.java:2120) 2019-09-30 11: 12: 30.553 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreTentlient(HiveMetaStoreClient.java:1674) 2019-09-30 11: 12: 30.553 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getTable (HiveMetaStoreClient.java:1666) 2019-09-30 11: 12: 30.553ИНФОРМАЦИЯ: в sun.reflect.NativeMethodAccessorImpl.invoke0 (собственный метод) 2019-09-30 11: 12: 30.553 ИНФОРМАЦИЯ: в sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 2019-09-30 11:12:30.553 ИНФОРМАЦИЯ: в sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) 2019-09-30 11: 12: 30.553 ИНФОРМАЦИЯ: в java.lang.reflect.Method.invoke (Method.java:498) 2019-09-30 11: 12: 30.553 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient.invoke (RetedingMetaStoreClient.java:208) 2019-09-30 11: 12: 30.554 ИНФОРМАЦИЯ: в com.sun.proxy. $ Proxy15.getTable (Неизвестный источник) 2019-09-30 11:12:30.554 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection.validateTable (HiveStreamingConnection.java:401) 2019-09-30 11: 12: 30.554 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java202) 2019-09-30 11: 12: 30.554 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:118) 2019-09-30 11: 12: 30.554 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection $ Builder.connect (HiveStreamingConnection.java:332) 2019-09-30 11: 12: 30.554 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.io.impl.formatter.IHiveStreamingOutputFormatImplin (inline.it)IHiveStreamingOutputFormatImpl.java:50) 2019-09-30 11: 12: 30.555 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.security.IHadoopSecurityHandlerFactory $ 3.run (IHadoopSecurityHandlerFactory.java-55: 55)30 11: 12: 30.555 ИНФОРМАЦИЯ: в java.security.AccessController.doPrivileged (собственный метод) 2019-09-30 11: 12: 30.555 ИНФОРМАЦИЯ: в javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-30 11: 12: 30.555 ИНФОРМАЦИЯ: в org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1730) 2019-09-30 11: 12: 30.555 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.impl.AbstractIUserGroupInformationImpl.doAs (AbstractIUserGroupInformationImpl.java:122) 2019-09-30 11: 12: 30.555 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.security.HadoopSecurityUtil.tilis. Java: 329) 2019-09-30 11: 12: 30.555 ИНФОРМАЦИЯ: на com.informatica.extensions.hivehdfssdk.wrt.HiveHdfsWrtPartitionDriver.init (HiveHdfsWrtPartitionDriver.java:299) 2019-09-30 11: 12: 31.549 INFO/ 09/30 11:12:31 ИНФОРМАЦИЯ metastore.RetryMetaStoreClient: RetriedMetaStoreClient пытается повторно подключиться как impUser1 (auth: TOKEN) 2019-09-30 11: 12: 31.577 INFO: 19/09/30 11:12:31 WARN transport.TIOStreamTransport: Ошибка закрытия выходного потокам. 2019-09-30 11: 12: 31.577 ИНФОРМАЦИЯ: java.net.SocketException: сокет закрыт 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: в java.net.SocketOutputStream.socketWrite (SocketOutputStream.java:118) 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: на java.net.SocketOutputStream.write (SocketOutputStream.java:155) 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: на java.io.BufferedOutputStream.flushBuffer (BufferedOutputStream.java:82) 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: в java.io.BufferedOutputStream.flush (BufferedOutputStream.java:140) 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: в java.io.FilterOutputStream.close (FilterOutputStream.java: 158) 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TIOStreamTransport.close (TIOStreamTransport.java:110) 2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: в организации.apache.thrift.transport.TSocket.close (TSocket.java:235)2019-09-30 11: 12: 31.578 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.close (HiveMetaStoreClient.java:631) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в org.apache. hadoop.hive.metastore.HiveMetaStoreClient.reconnect (HiveMetaStoreClient.java:367) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient $ 1.run (RetringMlita.tore)2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в java.security.AccessController.doPrivileged (собственный метод) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в javax.security.auth.Subject.doAs (Subject.java: 422) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1730) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient.invoke (RetriedMetaStoreClient.java:183) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: в com.sun.proxy. $ Proxy15.getTable (Неизвестный источник) 2019-09-30 11: 12: 31.579 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection.validateTable (HiveStreamingConnecion.java:401) 2019-09-30 11: 12: 31.580 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:202) 2019-09-30 11: 12: 31.580 ИНФОРМАЦИЯ: в организации.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:118) 2019-09-30 11: 12: 31.580 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection $ Builder.connect (HiveStreamingConnection.java:332) 2019-09-30 11: 12: 31.580 ИНФОРМАЦИЯ: at com.informatica.platform.dtm.executor.hadoop.io.impl.formatter.IHiveStreamingOutputFormatImpl.init (IHiveStreamingOutputFormatImpl.java:50) 2019-09-30 11: 12: 31.580ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.security.IHadoopSecurityHandlerFactory $ 3.run (IHadoopSecurityHandlerFactory.java:55) 2019-09-30 11: 12: 31.580 ИНФОРМАЦИЯ: в java.security.AccessControlled.PurityМетод) 2019-09-30 11: 12: 31.580 ИНФОРМАЦИЯ: в javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-30 11: 12: 31.581 ИНФОРМАЦИЯ: в org.apache.hadoop. security.UserGroupInformation.doAs (UserGroupInformation.java: 1730) 2019-09-30 11: 12: 31.581 ИНФОРМАЦИЯ: at com.informatica.platform.dtm.executor.hadoop.impl.AbstractIUserGroupInformationImpl.doAs (AbstractIUserGroupInformationImpl.java:122) 2019-09-30 11:12: 31.581 ИНФОРМАЦИЯ: на com.informatica.platform.dtm.executor.hadoop.security.HadoopSecurityUtil.doAs (HadoopSecurityUtil.java:329) 2019-09-30 11: 12: 31.581 ИНФОРМАЦИЯ: на com.informatica.extensions.hivehdfssdk. wrt.HiveHdfsWrtPartitionDriver.init (HiveHdfsWrtPartitionDriver.java:299) 2019-09-30 11: 12: 31.581 INFO: 19/09/30 11:12:31 INFO metastore.HiveMetaStoreClient: Закрыто соединение с metastore, текущие соединения: 1-09-30 11: 12: 31.581 ИНФОРМАЦИЯ: 19/09/30 11:12:31 ИНФОРМАЦИЯ metastore.HiveMetaStoreClient: Попытка подключения к метастару с использованием URI: //irrhdp651.informatica.com: 9083 2019-09-30 11: 12: 31.581 ИНФОРМАЦИЯ: 19/09/30 11:12:31 ИНФОРМАЦИЯ metastore.HiveMetaStoreClient: Открыто соединение с metastore, текущие соединения: 2 2019-09-30 11: 12: 31.589 ИНФОРМАЦИЯ: 19/09/30 11:12:31 WARN metastore.HiveMetaStoreClient: set_ugi() не удалось, вероятная причина: новый клиент говорит со старым сервером. Продолжая без этого. 2019-09-30 11: 12: 31.590 ИНФОРМАЦИЯ: org.apache.thrift.transport.TTransportException 2019-09-30 11: 12: 31.590 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TIOStreamTransport.read (TIOStreamTransport.java:132) 2019-09-30 11: 12: 31.590 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TTransport.readAll (TTransport.java:86) 2019-09-30 11: 12: 31.590 ИНФОРМАЦИЯ: в org.apache. thrift.protocol.TBinaryProtocol.readStringBody (TBinaryProtocol.java:380) 2019-09-30 11: 12: 31.590 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin (TBinaryProtocol.java:230) 2019-09-3011: 12: 31.591 ИНФОРМАЦИЯ: в org.apache.thrift.TServiceClient.receiveBase (TServiceClient.java:77)2019-09-30 11: 12: 31.591 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.recv_set_ugi (ThriftHiveMetastore.java:4998) 2019-09-30 11: 12: 31.591 ИНФОРМАЦИЯ: вorg.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.set_ugi (ThriftHiveMetastore.java:4984) 2019-09-30 11: 12: 31.591 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.li(HiveMetaStoreClient.java:566) 2019-09-30 11: 12: 31.591 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.reconnect (HiveMetaStoreClient.java:380) 2019-09-30 11: 12: 31.591ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient $ 1.run (RetedingMetaStoreClient.java:187) 2019-09-30 11: 12: 31.591 ИНФОРМАЦИЯ: в java.security.AccessController.doPrivileged (собственный метод) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: at javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: org.apache.hadoop.security.UserGroupInformation. doAs (UserGroupInformation.java:1730) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: at org.apache.hadoop.hive.metastore.RetringMetaStoreClient.invoke (RetriedMetaStoreClient.java:183) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: в com.sun.proxy. $ Proxy15.getTable (Неизвестный источник) 2019-09-30 11:12:31.592 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection.validateTable (HiveStreamingConnection.java:401) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java: java202) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:118) 2019-09-30 11: 12: 31.592 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection $ Builder.connect (HiveStreamingConnection.java:332) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.io.impl.formatter.IHiveStreamingOutputFormatImplin (inline.it)IHiveStreamingOutputFormatImpl.java:50) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: в com.informatica.platform.dtm.executor.hadoop.security.IHadoopSecurityHandlerFactory $ 3.run (IHadoopSecurityHandlerFactory.java:55)9-30 11: 12: 31.593 ИНФОРМАЦИЯ: в java.security.AccessController.doPrivileged (собственный метод) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: в javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: at org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1730) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: на com.infor.platform.dtm.executor.hadoop.impl.AbstractIUserGroupInformationImpl.doAs (AbstractIUserGroupInformationImpl.java:122) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: at com.infor.platform.dtm.executor.hadoop.security.HadoopSecurity. HadoopSecurityUtil.java:329) 2019-09-30 11: 12: 31.593 ИНФОРМАЦИЯ: на com.infor.extensions.hivehdfssdk.wrt.HiveHdfsWrtPartitionDriver.init (HiveHdfsWrtPartitionDriver.java:299) 319-09-3094: 129-09-3094: 19/09/30 11:12:31 ИНФОРМАЦИЯ metastore.HiveMetaStoreClient: Подключено к metastore. 2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: 19/09/30 11:12:31 WARN streaming.HiveStreamingConnection: Невозможно проверить таблицу для соединения: {metastore-uri: thrift: //irrhdp651.infor.com:9083, база данных: по умолчанию, таблица: table_name1, многораздельная таблица: false, динамическое разбиение: false, имя пользователя: impUser1, безопасный режим: false, запись-запись: StrictDelimitedInputWriter, информация агента: impUser1: irrhdp652.infor.com:Thread-12} 2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: org.apache.thrift.transport.TTransportException 2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: at org.apache.thrift.transport.TIOStreamTransport.read (TIOStreamTransport.java:132) 2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: в org.apache.thrift.transport.TTransport.readAll (TTransport.java:86) 2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: вorg.apache.thrift.protocol.TBinaryProtocol.readAll (TBinaryProtocol.java:429) 2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readI32 (TBinaryProtocol.java:318)2019-09-30 11: 12: 31.594 ИНФОРМАЦИЯ: в org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin (TBinaryProtocol.java:219) 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: в org.apache.thrift. TServiceClient.receiveBase (TServiceClient.java:77) 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.recv_get_table_req (ThriftHiveMetastore.java-092133)-30 11: 12: 31.595 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Client.get_table_req (ThriftHiveMetastore.java:2120) 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getTable (HiveMetaStoreClient.java:1674) 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getTable (HiveMe66). 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: в sun.reflect.NativeMethodAccessorImpl.invoke0 (собственный метод) 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: в sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.j::) 2019-09-30 11: 12: 31.595 ИНФОРМАЦИЯ: в сun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) 2019-09-30 11: 12: 31.596 ИНФОРМАЦИЯ: в java.lang.reflect.Method.invoke (Method.java:498) 2019-09-30 11:12: 31.596 ИНФОРМАЦИЯ: в org.apache.hadoop.hive.metastore.RetringMetaStoreClient.invoke (RetringMetaStoreClient.java:208) 2019-09-30 11: 12: 31.596 ИНФОРМАЦИЯ: в com.sun.proxy. $ Proxy15.getTable (Неизвестный источник) 2019-09-30 11: 12: 31.596 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection.validateTable (HiveStreamingConnection.java:401) 2019-09-30 11: 12: 31.596 ИНФО: at org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:202) 2019-09-30 11: 12: 31.596 ИНФОРМАЦИЯ: в org.apache.hive.streaming.HiveStreamingConnection. (HiveStreamingConnection.java:118) 2019-09-30 11: 12: 31.596 ИНФОРМАЦИЯ: at org.apache.hive.streaming.HiveStreamingConnection $ Builder.connect (HiveStreamingConnection.java:332) 2019-09-30 11: 12: 31.597 ИНФОРМАЦИЯ: на com.infor.platform.dtm.executor. hadoop.io.impl.formatter.IHiveStreamingOutputFormatImpl. init (IHiveStreamingOutputFormatImpl.java:50) 2019-09-30 11: 12: 31.597 ИНФОРМАЦИЯ: в com.infor.platform.dtm.executor.hadoop.security.IHadoopSecurityHandlerFactory $ 3.run (IHadoopSecurityHandlerFactory.java-55-)30 11: 12: 31.597 ИНФОРМАЦИЯ: в java.security.AccessController.doPrivileged (собственный метод) 2019-09-30 11: 12: 31.597 ИНФОРМАЦИЯ: в javax.security.auth.Subject.doAs (Subject.java:422) 2019-09-30 11: 12: 31.597 ИНФОРМАЦИЯ: at org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1730)