shining created HIVE-23489:
------------------------------
Summary: dynamic partition failed use insert overwrite
Key: HIVE-23489
URL: https://issues.apache.org/jira/browse/HIVE-23489
Project: Hive
Issue Type: Bug
Components: Metastore
Affects Versions: 2.1.1
Reporter: shining
SQL: insert *overwrite *table dzdz_fpxx_dzfp partition(nian) select * from
test.dzdz_fpxx_dzfp
{noformat}
create table dzdz_fpxx_dzfp (
FPDM string,
FPHM string,
KPRQ timestamp,
FPLY string)
partitioned by (nian string)
stored as parquet;
create table test.dzdz_fpxx_dzfp (
FPDM string,
FPHM string,
KPRQ timestamp,
FPLY string,
nian string)
stored as textfile
location "/origin/data/dzfp_origin/"
{noformat}
The execute insert sql:
SQL: insert overwrite table dzdz_fpxx_dzfp partition(nian) select * from
test.dzdz_fpxx_dzfp
{noformat}
INFO : Compiling
command(queryId=hive_20200519100412_12f2b39c-45f4-4f4c-9261-32ca86fa28db):
insert overwrite table dzdz_fpxx_dzfp partition(nian) select * from
test.dzdz_fpxx_dzfp
INFO : Semantic Analysis Completed
INFO : Returning Hive schema:
Schema(fieldSchemas:[FieldSchema(name:dzdz_fpxx_dzfp.fpdm, type:string,
comment:null), FieldSchema(name:dzdz_fpxx_dzfp.fphm, type:string,
comment:null), FieldSchema(name:dzdz_fpxx_dzfp.kprq, type:timestamp,
comment:null), FieldSchema(name:dzdz_fpxx_dzfp.tspz_dm, type:string,
comment:null), FieldSchema(name:dzdz_fpxx_dzfp.fpzt_bz, type:string,
comment:null), FieldSchema(name:dzdz_fpxx_dzfp.fply, type:string,
comment:null), FieldSchema(name:dzdz_fpxx_dzfp.nian, type:string,
comment:null)], properties:null)
INFO : Completed compiling
command(queryId=hive_20200519100412_12f2b39c-45f4-4f4c-9261-32ca86fa28db); Time
taken: 1.719 seconds
INFO : Executing
command(queryId=hive_20200519100412_12f2b39c-45f4-4f4c-9261-32ca86fa28db):
insert overwrite table dzdz_fpxx_dzfp partition(nian) select * from
test.dzdz_fpxx_dzfp
WARN :
INFO : Query ID = hive_20200519100412_12f2b39c-45f4-4f4c-9261-32ca86fa28db
INFO : Total jobs = 3
INFO : Launching Job 1 out of 3
INFO : Starting task [Stage-1:MAPRED] in serial mode
INFO : Number of reduce tasks is set to 0 since there's no reduce operator
INFO : number of splits:1
INFO : Submitting tokens for job: job_1589451904439_0049
INFO : Executing with tokens: []
INFO : The url to track the job:
http://qcj37.hde.com:8088/proxy/application_1589451904439_0049/
INFO : Starting Job = job_1589451904439_0049, Tracking URL =
http://qcj37.hde.com:8088/proxy/application_1589451904439_0049/
INFO : Kill Command = /usr/hdp/current/hadoop-client/bin/hadoop job -kill
job_1589451904439_0049
INFO : Hadoop job information for Stage-1: number of mappers: 1; number of
reducers: 0
INFO : 2020-05-19 10:06:56,823 Stage-1 map = 0%, reduce = 0%
INFO : 2020-05-19 10:07:06,317 Stage-1 map = 100%, reduce = 0%, Cumulative
CPU 4.3 sec
INFO : MapReduce Total cumulative CPU time: 4 seconds 300 msec
INFO : Ended Job = job_1589451904439_0049
INFO : Starting task [Stage-7:CONDITIONAL] in serial mode
INFO : Stage-4 is selected by condition resolver.
INFO : Stage-3 is filtered out by condition resolver.
INFO : Stage-5 is filtered out by condition resolver.
INFO : Starting task [Stage-4:MOVE] in serial mode
INFO : Moving data to directory
hdfs://mycluster/warehouse/tablespace/managed/hive/dzdz_fpxx_dzfp/.hive-staging_hive_2020-05-19_10-04-12_468_7695595367555279265-3/-ext-10000
from
hdfs://mycluster/warehouse/tablespace/managed/hive/dzdz_fpxx_dzfp/.hive-staging_hive_2020-05-19_10-04-12_468_7695595367555279265-3/-ext-10002
INFO : Starting task [Stage-0:MOVE] in serial mode
INFO : Loading data to table default.dzdz_fpxx_dzfp partition (nian=null) from
hdfs://mycluster/warehouse/tablespace/managed/hive/dzdz_fpxx_dzfp/.hive-staging_hive_2020-05-19_10-04-12_468_7695595367555279265-3/-ext-10000
INFO :
ERROR : FAILED: Execution Error, return code 1 from
org.apache.hadoop.hive.ql.exec.MoveTask. Exception when loading 2 in table
dzdz_fpxx_dzfp with
loadPath=hdfs://mycluster/warehouse/tablespace/managed/hive/dzdz_fpxx_dzfp/.hive-staging_hive_2020-05-19_10-04-12_468_7695595367555279265-3/-ext-10000
INFO : MapReduce Jobs Launched:
INFO : Stage-Stage-1: Map: 1 Cumulative CPU: 4.3 sec HDFS Read: 8015 HDFS
Write: 2511 SUCCESS
INFO : Total MapReduce CPU Time Spent: 4 seconds 300 msec
INFO : Completed executing
command(queryId=hive_20200519100412_12f2b39c-45f4-4f4c-9261-32ca86fa28db); Time
taken: 297.35 seconds
2020-05-19 10:11:54,635 DEBUG transport.TSaslTransport
(TSaslTransport.java:flush(496)) - writing data length: 117
2020-05-19 10:11:54,638 DEBUG transport.TSaslTransport
(TSaslTransport.java:readFrame(457)) - CLIENT: reading data length: 96
2020-05-19 10:11:54,649 DEBUG transport.TSaslTransport
(TSaslTransport.java:flush(496)) - writing data length: 96
2020-05-19 10:11:54,714 DEBUG transport.TSaslTransport
(TSaslTransport.java:readFrame(457)) - CLIENT: reading data length: 42
Error: Error while processing statement: FAILED: Execution Error, return code 1
from org.apache.hadoop.hive.ql.exec.MoveTask. Exception when loading 2 in table
dzdz_fpxx_dzfp with
loadPath=hdfs://mycluster/warehouse/tablespace/managed/hive/dzdz_fpxx_dzfp/.hive-staging_hive_2020-05-19_10-04-12_468_7695595367555279265-3/-ext-10000
(state=08S01,code=1)
{noformat}
I find error log as follows in hive metastore:
{noformat}
2020-05-19 08:37:23,957 ERROR metastore.RetryingHMSHandler
(RetryingHMSHandler.java:invokeInternal(175)) -
NoSuchObjectException(message:partition values=[ujm])
at
org.apache.hadoop.hive.metastore.ObjectStore.getPartition(ObjectStore.java:2003)
at sun.reflect.GeneratedMethodAccessor15.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hadoop.hive.metastore.RawStoreProxy.invoke(RawStoreProxy.java:101)
at com.sun.proxy.$Proxy26.getPartition(Unknown Source)
at
org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.get_partition(HiveMetaStore.java:3553)
at
org.apache.hadoop.hive.metastore.events.InsertEvent.<init>(InsertEvent.java:62)
at
org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.fire_listener_event(HiveMetaStore.java:6737)
at sun.reflect.GeneratedMethodAccessor14.invoke(Unknown Source)
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.$Proxy28.fire_listener_event(Unknown Source)
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Processor$fire_listener_event.getResult(ThriftHiveMetastore.java:14208)
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Processor$fire_listener_event.getResult(ThriftHiveMetastore.java:14193)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
at
org.apache.hadoop.hive.metastore.TUGIBasedProcessor$1.run(TUGIBasedProcessor.java:110)
at
org.apache.hadoop.hive.metastore.TUGIBasedProcessor$1.run(TUGIBasedProcessor.java:106)
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:1875)
at
org.apache.hadoop.hive.metastore.TUGIBasedProcessor.process(TUGIBasedProcessor.java:118)
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:286)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2020-05-19 08:37:23,957 DEBUG log.PerfLogger (PerfLogger.java:PerfLogEnd(179))
- </PERFLOG method=fire_listener_event start=1589848643184 end=1589848643957
duration=773 from=org.apache.hadoop.hive.metastore.RetryingHMSHandler
threadId=56 retryCount=-1 error=true>
2020-05-19 08:37:23,958 ERROR thrift.ProcessFunction
(ProcessFunction.java:process(41)) - Internal error processing
fire_listener_event
org.apache.hadoop.hive.metastore.api.NoSuchObjectException: partition
values=[ujm]
at
org.apache.hadoop.hive.metastore.ObjectStore.getPartition(ObjectStore.java:2003)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at sun.reflect.GeneratedMethodAccessor15.invoke(Unknown Source) ~[?:?]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0-internal]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0-internal]
at
org.apache.hadoop.hive.metastore.RawStoreProxy.invoke(RawStoreProxy.java:101)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at com.sun.proxy.$Proxy26.getPartition(Unknown Source) ~[?:?]
at
org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.get_partition(HiveMetaStore.java:3553)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.hadoop.hive.metastore.events.InsertEvent.<init>(InsertEvent.java:62)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.fire_listener_event(HiveMetaStore.java:6737)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at sun.reflect.GeneratedMethodAccessor14.invoke(Unknown Source) ~[?:?]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0-internal]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0-internal]
at
org.apache.hadoop.hive.metastore.RetryingHMSHandler.invokeInternal(RetryingHMSHandler.java:140)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.hadoop.hive.metastore.RetryingHMSHandler.invoke(RetryingHMSHandler.java:99)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at com.sun.proxy.$Proxy28.fire_listener_event(Unknown Source) ~[?:?]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Processor$fire_listener_event.getResult(ThriftHiveMetastore.java:14208)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Processor$fire_listener_event.getResult(ThriftHiveMetastore.java:14193)
~[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.hadoop.hive.metastore.TUGIBasedProcessor$1.run(TUGIBasedProcessor.java:110)
[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.hadoop.hive.metastore.TUGIBasedProcessor$1.run(TUGIBasedProcessor.java:106)
[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at java.security.AccessController.doPrivileged(Native Method)
~[?:1.8.0-internal]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0-internal]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875)
[hadoop-common-3.0.0-cdh6.2.0.jar:?]
at
org.apache.hadoop.hive.metastore.TUGIBasedProcessor.process(TUGIBasedProcessor.java:118)
[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:286)
[hive-exec-2.1.1-cdh6.2.0.jar:2.1.1-cdh6.2.0]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0-internal]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0-internal]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0-internal]
2020-05-19 08:37:23,976 DEBUG ipc.Client (ClientCache.java:stopClient(97)) -
stopping client from cache: org.apache.hadoop.ipc.Client@2c66e678
{noformat}
I guess metastore could not find partition,and disconnect connection.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)