(DEPRECATED) Apache Flink Mailing List archive.

[jira] [Created] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

classic Classic list List threaded Threaded
♦
♦
 1 message Options
Shang Yuanchun (Jira)
Reply | Threaded
Open this post in threaded view
♦
♦
|

[jira] [Created] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

Shang Yuanchun (Jira)
Dian Fu created FLINK-17576:
-------------------------------

             Summary: HiveTableSinkTest and TableEnvHiveConnectorTest are instable
                 Key: FLINK-17576
                 URL: https://issues.apache.org/jira/browse/FLINK-17576
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Hive, Tests
    Affects Versions: 1.11.0
            Reporter: Dian Fu


HiveTableSinkTest and TableEnvHiveConnectorTest failed with the following exception:
{code:java}
2020-05-08T09:38:44.5916441Z [ERROR] testWriteComplexType(org.apache.flink.connectors.hive.HiveTableSinkTest)  Time elapsed: 1.362 s  <<< ERROR!
2020-05-08T09:38:44.5932270Z java.util.concurrent.ExecutionException: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (e27d50c5a780264a576aa8a21a6dd6c6)
2020-05-08T09:38:44.5938598Z at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2020-05-08T09:38:44.5939435Z at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2020-05-08T09:38:44.5939970Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1663)
2020-05-08T09:38:44.5940551Z at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:74)
2020-05-08T09:38:44.5941188Z at org.apache.flink.table.planner.delegation.ExecutorBase.execute(ExecutorBase.java:52)
2020-05-08T09:38:44.5941834Z at org.apache.flink.table.api.internal.TableEnvironmentImpl.execute(TableEnvironmentImpl.java:916)
2020-05-08T09:38:44.5945405Z at org.apache.flink.connectors.hive.HiveTableSinkTest.testWriteComplexType(HiveTableSinkTest.java:143)
2020-05-08T09:38:44.5946105Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:38:44.5946628Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:38:44.5947106Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:38:44.5947770Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:38:44.5948393Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-05-08T09:38:44.5949102Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-05-08T09:38:44.5949853Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-05-08T09:38:44.5950587Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-05-08T09:38:44.5951763Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runTestMethod(FlinkStandaloneHiveRunner.java:169)
2020-05-08T09:38:44.5952660Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:154)
2020-05-08T09:38:44.5953829Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:92)
2020-05-08T09:38:44.5966233Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-05-08T09:38:44.5967051Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-05-08T09:38:44.5968062Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-05-08T09:38:44.5968949Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-05-08T09:38:44.5969824Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-05-08T09:38:44.5970751Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-05-08T09:38:44.5971584Z at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-05-08T09:38:44.5972386Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:38:44.5973469Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:38:44.5974147Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:38:44.5974684Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-05-08T09:38:44.5975227Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-05-08T09:38:44.5975827Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-05-08T09:38:44.5976533Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-05-08T09:38:44.5977627Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-05-08T09:38:44.5978552Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-05-08T09:38:44.5979527Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-05-08T09:38:44.5980556Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-05-08T09:38:44.5981696Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-05-08T09:38:44.5982559Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-05-08T09:38:44.5983422Z Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (e27d50c5a780264a576aa8a21a6dd6c6)
2020-05-08T09:38:44.5984215Z at org.apache.flink.runtime.dispatcher.Dispatcher.requestJobResult(Dispatcher.java:563)
2020-05-08T09:38:44.5984798Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:38:44.5985384Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:38:44.5986037Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:38:44.5986721Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:38:44.5987383Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:284)
2020-05-08T09:38:44.5988199Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:199)
2020-05-08T09:38:44.5989080Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
2020-05-08T09:38:44.5989914Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
2020-05-08T09:38:44.5990781Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2020-05-08T09:38:44.5991545Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2020-05-08T09:38:44.5992368Z at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
2020-05-08T09:38:44.5993122Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2020-05-08T09:38:44.5993826Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
2020-05-08T09:38:44.5994473Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-05-08T09:38:44.5995161Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-05-08T09:38:44.5995794Z at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
2020-05-08T09:38:44.5996445Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2020-05-08T09:38:44.5997053Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2020-05-08T09:38:44.5997658Z at akka.actor.ActorCell.invoke(ActorCell.scala:561)
2020-05-08T09:38:44.5998227Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2020-05-08T09:38:44.5998805Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2020-05-08T09:38:44.5999332Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2020-05-08T09:38:44.5999920Z at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2020-05-08T09:38:44.6000703Z at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2020-05-08T09:38:44.6001454Z at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2020-05-08T09:38:44.6002040Z at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2020-05-08T09:38:44.6002538Z
2020-05-08T09:38:44.6003181Z [ERROR] testInsertIntoNonPartitionTable(org.apache.flink.connectors.hive.HiveTableSinkTest)  Time elapsed: 0.05 s  <<< ERROR!
2020-05-08T09:38:44.6004907Z org.apache.flink.table.catalog.exceptions.TableAlreadyExistException: Table (or view) default.dest already exists in Catalog test-catalog.
2020-05-08T09:38:44.6005671Z at org.apache.flink.table.catalog.hive.HiveCatalog.createTable(HiveCatalog.java:381)
2020-05-08T09:38:44.6006731Z at org.apache.flink.connectors.hive.HiveTableSinkTest.createHiveDestTable(HiveTableSinkTest.java:221)
2020-05-08T09:38:44.6007458Z at org.apache.flink.connectors.hive.HiveTableSinkTest.createHiveDestTable(HiveTableSinkTest.java:233)
2020-05-08T09:38:44.6008204Z at org.apache.flink.connectors.hive.HiveTableSinkTest.testInsertIntoNonPartitionTable(HiveTableSinkTest.java:91)
2020-05-08T09:38:44.6008828Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:38:44.6009371Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:38:44.6010558Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:38:44.6011208Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:38:44.6011809Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-05-08T09:38:44.6012473Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-05-08T09:38:44.6013197Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-05-08T09:38:44.6013851Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-05-08T09:38:44.6014545Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runTestMethod(FlinkStandaloneHiveRunner.java:169)
2020-05-08T09:38:44.6015457Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:154)
2020-05-08T09:38:44.6016216Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:92)
2020-05-08T09:38:44.6017023Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-05-08T09:38:44.6017701Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-05-08T09:38:44.6018172Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-05-08T09:38:44.6018703Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-05-08T09:38:44.6019284Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-05-08T09:38:44.6019938Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-05-08T09:38:44.6020713Z at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-05-08T09:38:44.6021472Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:38:44.6022069Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:38:44.6022685Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:38:44.6023296Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-05-08T09:38:44.6023904Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-05-08T09:38:44.6024527Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-05-08T09:38:44.6025235Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-05-08T09:38:44.6025945Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-05-08T09:38:44.6026745Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-05-08T09:38:44.6027625Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-05-08T09:38:44.6028430Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-05-08T09:38:44.6029179Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-05-08T09:38:44.6029875Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-05-08T09:38:44.6030663Z Caused by: AlreadyExistsException(message:Table dest already exists)
2020-05-08T09:38:44.6031755Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_table_with_environment_context_result$create_table_with_environment_context_resultStandardScheme.read(ThriftHiveMetastore.java:42052)
2020-05-08T09:38:44.6033379Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_table_with_environment_context_result$create_table_with_environment_context_resultStandardScheme.read(ThriftHiveMetastore.java:42038)
2020-05-08T09:38:44.6034566Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_table_with_environment_context_result.read(ThriftHiveMetastore.java:41964)
2020-05-08T09:38:44.6035344Z at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
2020-05-08T09:38:44.6036352Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_create_table_with_environment_context(ThriftHiveMetastore.java:1199)
2020-05-08T09:38:44.6037302Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.create_table_with_environment_context(ThriftHiveMetastore.java:1185)
2020-05-08T09:38:44.6038089Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.create_table_with_environment_context(HiveMetaStoreClient.java:2399)
2020-05-08T09:38:44.6038849Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createTable(HiveMetaStoreClient.java:752)
2020-05-08T09:38:44.6039507Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createTable(HiveMetaStoreClient.java:740)
2020-05-08T09:38:44.6040073Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:38:44.6040752Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:38:44.6041435Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:38:44.6041899Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:38:44.6042490Z at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:169)
2020-05-08T09:38:44.6042926Z at com.sun.proxy.$Proxy34.createTable(Unknown Source)
2020-05-08T09:38:44.6043476Z at org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.createTable(HiveMetastoreClientWrapper.java:142)
2020-05-08T09:38:44.6044191Z at org.apache.flink.table.catalog.hive.HiveCatalog.createTable(HiveCatalog.java:378)
2020-05-08T09:38:44.6044593Z ... 34 more
2020-05-08T09:38:44.6044759Z
2020-05-08T09:38:45.4944094Z [INFO] Running org.apache.flink.connectors.hive.TableEnvHiveConnectorTest
2020-05-08T09:38:57.2455895Z OK
2020-05-08T09:38:57.5074904Z OK
2020-05-08T09:39:54.4485216Z WARNING: Hive-on-MR is deprecated in Hive 2 and may not be available in the future versions. Consider using a different execution engine (i.e. spark, tez) or using Hive 1.X releases.
2020-05-08T09:39:54.4486112Z Query ID = agent02_azpcontainer_20200508093954_5b7c9f45-4c3c-4baa-9192-cec3724fd063
2020-05-08T09:39:54.4486420Z Total jobs = 3
2020-05-08T09:39:54.4486631Z Launching Job 1 out of 3
2020-05-08T09:39:54.4493419Z Number of reduce tasks is set to 0 since there's no reduce operator
2020-05-08T09:39:54.6913698Z Job running in-process (local Hadoop)
2020-05-08T09:39:54.6931724Z 2020-05-08 09:39:54,692 Stage-1 map = 0%,  reduce = 0%
2020-05-08T09:39:54.7230751Z 2020-05-08 09:39:54,722 Stage-1 map = 100%,  reduce = 0%
2020-05-08T09:39:54.7268752Z Ended Job = job_local1575498928_0003
2020-05-08T09:39:54.7282475Z Stage-3 is selected by condition resolver.
2020-05-08T09:39:54.7283011Z Stage-2 is filtered out by condition resolver.
2020-05-08T09:39:54.7283698Z Stage-4 is filtered out by condition resolver.
2020-05-08T09:39:54.7293228Z Moving data to directory file:/tmp/junit1597676277387724188/warehouse/db1.db/src1/.hive-staging_hive_2020-05-08_09-39-54_359_5169339369873513430-1/-ext-10000
2020-05-08T09:39:54.7619636Z Loading data to table db1.src1
2020-05-08T09:39:54.8385179Z MapReduce Jobs Launched:
2020-05-08T09:39:54.8386671Z Stage-Stage-1:  HDFS Read: 0 HDFS Write: 0 SUCCESS
2020-05-08T09:39:54.8387003Z Total MapReduce CPU Time Spent: 0 msec
2020-05-08T09:39:54.8387337Z OK
2020-05-08T09:39:56.4934855Z OK
2020-05-08T09:39:56.5937839Z OK
2020-05-08T09:39:58.5593808Z OK
2020-05-08T09:39:58.6535469Z OK
2020-05-08T09:39:58.7554994Z OK
2020-05-08T09:39:58.7831835Z OK
2020-05-08T09:39:58.8160236Z OK
2020-05-08T09:39:58.8509517Z OK
2020-05-08T09:39:58.8633482Z Loading data to table db1.src
2020-05-08T09:39:58.9445381Z OK
2020-05-08T09:40:02.0134976Z FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.0813385Z FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.1006755Z FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.1427929Z OK
2020-05-08T09:40:02.1877136Z [ERROR] Tests run: 21, Failures: 0, Errors: 4, Skipped: 2, Time elapsed: 76.685 s <<< FAILURE! - in org.apache.flink.connectors.hive.TableEnvHiveConnectorTest
2020-05-08T09:40:02.1878103Z [ERROR] testDefaultPartitionName(org.apache.flink.connectors.hive.TableEnvHiveConnectorTest)  Time elapsed: 3.191 s  <<< ERROR!
2020-05-08T09:40:02.1878675Z java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-05-08T09:40:02.1879172Z at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2020-05-08T09:40:02.1879747Z at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2020-05-08T09:40:02.1880286Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1663)
2020-05-08T09:40:02.1881369Z at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:74)
2020-05-08T09:40:02.1881929Z at org.apache.flink.table.planner.delegation.ExecutorBase.execute(ExecutorBase.java:52)
2020-05-08T09:40:02.1882689Z at org.apache.flink.table.api.internal.TableEnvironmentImpl.execute(TableEnvironmentImpl.java:916)
2020-05-08T09:40:02.1883216Z at org.apache.flink.table.api.TableUtils.collectToList(TableUtils.java:85)
2020-05-08T09:40:02.1884413Z at org.apache.flink.connectors.hive.TableEnvHiveConnectorTest.testDefaultPartitionName(TableEnvHiveConnectorTest.java:106)
2020-05-08T09:40:02.1885239Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:40:02.1886075Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:40:02.1886761Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.1887300Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.1887851Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-05-08T09:40:02.1888403Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-05-08T09:40:02.1888874Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-05-08T09:40:02.1889500Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-05-08T09:40:02.1890020Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runTestMethod(FlinkStandaloneHiveRunner.java:169)
2020-05-08T09:40:02.1894803Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:154)
2020-05-08T09:40:02.1895796Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:92)
2020-05-08T09:40:02.1896503Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-05-08T09:40:02.1897131Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-05-08T09:40:02.1897749Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-05-08T09:40:02.1898405Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-05-08T09:40:02.1899264Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-05-08T09:40:02.1899935Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-05-08T09:40:02.1900618Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.1901425Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.1902191Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.1902841Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-05-08T09:40:02.1903518Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-05-08T09:40:02.1904171Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-05-08T09:40:02.1905065Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-05-08T09:40:02.1905855Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-05-08T09:40:02.1906654Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-05-08T09:40:02.1907706Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-05-08T09:40:02.1908493Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-05-08T09:40:02.1909217Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-05-08T09:40:02.1909955Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-05-08T09:40:02.1910663Z Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-05-08T09:40:02.1911517Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
2020-05-08T09:40:02.1912462Z at org.apache.flink.client.program.PerJobMiniClusterFactory$PerJobMiniClusterJobClient.lambda$getJobExecutionResult$2(PerJobMiniClusterFactory.java:179)
2020-05-08T09:40:02.1913762Z at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2020-05-08T09:40:02.1914637Z at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2020-05-08T09:40:02.1915388Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-05-08T09:40:02.1916119Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2020-05-08T09:40:02.1917085Z at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229)
2020-05-08T09:40:02.1917933Z at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2020-05-08T09:40:02.1918701Z at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2020-05-08T09:40:02.1919480Z at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-05-08T09:40:02.1920131Z at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2020-05-08T09:40:02.1920772Z at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:890)
2020-05-08T09:40:02.1921625Z at akka.dispatch.OnComplete.internal(Future.scala:264)
2020-05-08T09:40:02.1922178Z at akka.dispatch.OnComplete.internal(Future.scala:261)
2020-05-08T09:40:02.1922718Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
2020-05-08T09:40:02.1923375Z at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
2020-05-08T09:40:02.1924014Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-05-08T09:40:02.1924841Z at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)
2020-05-08T09:40:02.1925627Z at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
2020-05-08T09:40:02.1926319Z at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
2020-05-08T09:40:02.1926996Z at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
2020-05-08T09:40:02.1927720Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
2020-05-08T09:40:02.1928567Z at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
2020-05-08T09:40:02.1929329Z at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
2020-05-08T09:40:02.1929984Z at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
2020-05-08T09:40:02.1930641Z at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-05-08T09:40:02.1931456Z at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
2020-05-08T09:40:02.1932304Z at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
2020-05-08T09:40:02.1933210Z at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2020-05-08T09:40:02.1934044Z at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2020-05-08T09:40:02.1934899Z at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
2020-05-08T09:40:02.1935581Z at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
2020-05-08T09:40:02.1936203Z at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
2020-05-08T09:40:02.1936956Z at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
2020-05-08T09:40:02.1937707Z at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2020-05-08T09:40:02.1938395Z at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2020-05-08T09:40:02.1939096Z at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2020-05-08T09:40:02.1939777Z at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2020-05-08T09:40:02.1940540Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2020-05-08T09:40:02.1941702Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:112)
2020-05-08T09:40:02.1942721Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
2020-05-08T09:40:02.1943727Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:189)
2020-05-08T09:40:02.1946503Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:183)
2020-05-08T09:40:02.1947357Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:177)
2020-05-08T09:40:02.1948239Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:497)
2020-05-08T09:40:02.1949045Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:384)
2020-05-08T09:40:02.1949693Z at sun.reflect.GeneratedMethodAccessor46.invoke(Unknown Source)
2020-05-08T09:40:02.1950329Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.1950963Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.1951755Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:284)
2020-05-08T09:40:02.1952473Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:199)
2020-05-08T09:40:02.1953417Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
2020-05-08T09:40:02.1954212Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
2020-05-08T09:40:02.1955031Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2020-05-08T09:40:02.1955651Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2020-05-08T09:40:02.1956318Z at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
2020-05-08T09:40:02.1956946Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2020-05-08T09:40:02.1957628Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
2020-05-08T09:40:02.1958290Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-05-08T09:40:02.1958959Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-05-08T09:40:02.1959598Z at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
2020-05-08T09:40:02.1960197Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2020-05-08T09:40:02.1960845Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2020-05-08T09:40:02.1961540Z at akka.actor.ActorCell.invoke(ActorCell.scala:561)
2020-05-08T09:40:02.1962127Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2020-05-08T09:40:02.1962677Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2020-05-08T09:40:02.1963303Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2020-05-08T09:40:02.1963710Z ... 4 more
2020-05-08T09:40:02.1964182Z Caused by: java.lang.OutOfMemoryError: unable to create new native thread
2020-05-08T09:40:02.1964816Z at java.lang.Thread.start0(Native Method)
2020-05-08T09:40:02.1965294Z at java.lang.Thread.start(Thread.java:717)
2020-05-08T09:40:02.1965949Z at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.processInput(SourceStreamTask.java:133)
2020-05-08T09:40:02.1966867Z at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:206)
2020-05-08T09:40:02.1967767Z at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:196)
2020-05-08T09:40:02.1968639Z at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:503)
2020-05-08T09:40:02.1969406Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:483)
2020-05-08T09:40:02.1970296Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:713)
2020-05-08T09:40:02.1970944Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:539)
2020-05-08T09:40:02.1971568Z at java.lang.Thread.run(Thread.java:748)
2020-05-08T09:40:02.1971844Z
2020-05-08T09:40:02.1972463Z [ERROR] testInsertOverwrite(org.apache.flink.connectors.hive.TableEnvHiveConnectorTest)  Time elapsed: 0.116 s  <<< ERROR!
2020-05-08T09:40:02.1973835Z java.lang.IllegalArgumentException: Failed to executeQuery Hive query create database db1: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.1975322Z at com.klarna.hiverunner.HiveServerContainer.executeStatement(HiveServerContainer.java:143)
2020-05-08T09:40:02.1976209Z at com.klarna.hiverunner.builder.HiveShellBase.executeStatementsWithCommandShellEmulation(HiveShellBase.java:121)
2020-05-08T09:40:02.1977145Z at com.klarna.hiverunner.builder.HiveShellBase.executeScriptWithCommandShellEmulation(HiveShellBase.java:110)
2020-05-08T09:40:02.1977986Z at com.klarna.hiverunner.builder.HiveShellBase.execute(HiveShellBase.java:129)
2020-05-08T09:40:02.1978847Z at org.apache.flink.connectors.hive.TableEnvHiveConnectorTest.testInsertOverwrite(TableEnvHiveConnectorTest.java:238)
2020-05-08T09:40:02.1979610Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:40:02.1980251Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:40:02.1981013Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.1981814Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.1982562Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-05-08T09:40:02.1983409Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-05-08T09:40:02.1984113Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-05-08T09:40:02.1984996Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-05-08T09:40:02.1985742Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runTestMethod(FlinkStandaloneHiveRunner.java:169)
2020-05-08T09:40:02.1986654Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:154)
2020-05-08T09:40:02.1987532Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:92)
2020-05-08T09:40:02.1988310Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-05-08T09:40:02.1988950Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-05-08T09:40:02.1989594Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-05-08T09:40:02.1990247Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-05-08T09:40:02.1990883Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-05-08T09:40:02.1991751Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-05-08T09:40:02.1992455Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.1993245Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.1993917Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.1994676Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-05-08T09:40:02.1995261Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-05-08T09:40:02.1995958Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-05-08T09:40:02.1996725Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-05-08T09:40:02.1997542Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-05-08T09:40:02.1998499Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-05-08T09:40:02.1999330Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-05-08T09:40:02.2000177Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-05-08T09:40:02.2000934Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-05-08T09:40:02.2001791Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-05-08T09:40:02.2002957Z Caused by: org.apache.hive.service.cli.HiveSQLException: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.2004116Z at org.apache.hive.service.cli.operation.Operation.toSQLException(Operation.java:380)
2020-05-08T09:40:02.2005005Z at org.apache.hive.service.cli.operation.SQLOperation.runQuery(SQLOperation.java:257)
2020-05-08T09:40:02.2005745Z at org.apache.hive.service.cli.operation.SQLOperation.runInternal(SQLOperation.java:293)
2020-05-08T09:40:02.2006515Z at org.apache.hive.service.cli.operation.Operation.run(Operation.java:320)
2020-05-08T09:40:02.2007317Z at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:530)
2020-05-08T09:40:02.2008209Z at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatement(HiveSessionImpl.java:500)
2020-05-08T09:40:02.2008976Z at org.apache.hive.service.cli.CLIService.executeStatement(CLIService.java:265)
2020-05-08T09:40:02.2009739Z at com.klarna.hiverunner.HiveServerContainer.executeStatement(HiveServerContainer.java:116)
2020-05-08T09:40:02.2010277Z ... 34 more
2020-05-08T09:40:02.2010807Z Caused by: org.apache.hadoop.hive.ql.metadata.HiveException: Database db1 already exists
2020-05-08T09:40:02.2011697Z at org.apache.hadoop.hive.ql.exec.DDLTask.createDatabase(DDLTask.java:4247)
2020-05-08T09:40:02.2012387Z at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:319)
2020-05-08T09:40:02.2013040Z at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:199)
2020-05-08T09:40:02.2013834Z at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:100)
2020-05-08T09:40:02.2014628Z at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:2183)
2020-05-08T09:40:02.2015266Z at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1839)
2020-05-08T09:40:02.2015878Z at org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:1526)
2020-05-08T09:40:02.2016484Z at org.apache.hadoop.hive.ql.Driver.run(Driver.java:1237)
2020-05-08T09:40:02.2017073Z at org.apache.hadoop.hive.ql.Driver.run(Driver.java:1232)
2020-05-08T09:40:02.2017723Z at org.apache.hive.service.cli.operation.SQLOperation.runQuery(SQLOperation.java:255)
2020-05-08T09:40:02.2018263Z ... 40 more
2020-05-08T09:40:02.2018703Z Caused by: AlreadyExistsException(message:Database db1 already exists)
2020-05-08T09:40:02.2019631Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result$create_database_resultStandardScheme.read(ThriftHiveMetastore.java:26487)
2020-05-08T09:40:02.2020824Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result$create_database_resultStandardScheme.read(ThriftHiveMetastore.java:26473)
2020-05-08T09:40:02.2022044Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result.read(ThriftHiveMetastore.java:26407)
2020-05-08T09:40:02.2022859Z at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
2020-05-08T09:40:02.2023761Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_create_database(ThriftHiveMetastore.java:749)
2020-05-08T09:40:02.2024792Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.create_database(ThriftHiveMetastore.java:736)
2020-05-08T09:40:02.2025682Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createDatabase(HiveMetaStoreClient.java:727)
2020-05-08T09:40:02.2026541Z at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source)
2020-05-08T09:40:02.2027193Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2027866Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2028536Z at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:173)
2020-05-08T09:40:02.2029209Z at com.sun.proxy.$Proxy33.createDatabase(Unknown Source)
2020-05-08T09:40:02.2029824Z at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source)
2020-05-08T09:40:02.2030493Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2031244Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2031998Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient$SynchronizedHandler.invoke(HiveMetaStoreClient.java:2330)
2020-05-08T09:40:02.2032716Z at com.sun.proxy.$Proxy33.createDatabase(Unknown Source)
2020-05-08T09:40:02.2033414Z at org.apache.hadoop.hive.ql.metadata.Hive.createDatabase(Hive.java:427)
2020-05-08T09:40:02.2034174Z at org.apache.hadoop.hive.ql.exec.DDLTask.createDatabase(DDLTask.java:4243)
2020-05-08T09:40:02.2034959Z ... 49 more
2020-05-08T09:40:02.2035232Z
2020-05-08T09:40:02.2036012Z [ERROR] testDifferentFormats(org.apache.flink.connectors.hive.TableEnvHiveConnectorTest)  Time elapsed: 0.031 s  <<< ERROR!
2020-05-08T09:40:02.2037188Z java.lang.IllegalArgumentException: Failed to executeQuery Hive query create database db1: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.2038329Z at com.klarna.hiverunner.HiveServerContainer.executeStatement(HiveServerContainer.java:143)
2020-05-08T09:40:02.2039176Z at com.klarna.hiverunner.builder.HiveShellBase.executeStatementsWithCommandShellEmulation(HiveShellBase.java:121)
2020-05-08T09:40:02.2040066Z at com.klarna.hiverunner.builder.HiveShellBase.executeScriptWithCommandShellEmulation(HiveShellBase.java:110)
2020-05-08T09:40:02.2040964Z at com.klarna.hiverunner.builder.HiveShellBase.execute(HiveShellBase.java:129)
2020-05-08T09:40:02.2042010Z at org.apache.flink.connectors.hive.TableEnvHiveConnectorTest.readWriteFormat(TableEnvHiveConnectorTest.java:142)
2020-05-08T09:40:02.2042941Z at org.apache.flink.connectors.hive.TableEnvHiveConnectorTest.testDifferentFormats(TableEnvHiveConnectorTest.java:135)
2020-05-08T09:40:02.2043764Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:40:02.2044514Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:40:02.2045198Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2045812Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2046423Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-05-08T09:40:02.2047134Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-05-08T09:40:02.2047860Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-05-08T09:40:02.2048579Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-05-08T09:40:02.2049372Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runTestMethod(FlinkStandaloneHiveRunner.java:169)
2020-05-08T09:40:02.2050242Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:154)
2020-05-08T09:40:02.2051230Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:92)
2020-05-08T09:40:02.2051916Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-05-08T09:40:02.2052516Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-05-08T09:40:02.2053144Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-05-08T09:40:02.2054136Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-05-08T09:40:02.2055027Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-05-08T09:40:02.2055775Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-05-08T09:40:02.2056731Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.2057369Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.2058109Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.2058580Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-05-08T09:40:02.2059127Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-05-08T09:40:02.2059523Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-05-08T09:40:02.2060161Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-05-08T09:40:02.2060798Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-05-08T09:40:02.2061500Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-05-08T09:40:02.2062191Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-05-08T09:40:02.2062826Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-05-08T09:40:02.2063446Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-05-08T09:40:02.2063921Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-05-08T09:40:02.2064783Z Caused by: org.apache.hive.service.cli.HiveSQLException: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.2065630Z at org.apache.hive.service.cli.operation.Operation.toSQLException(Operation.java:380)
2020-05-08T09:40:02.2066238Z at org.apache.hive.service.cli.operation.SQLOperation.runQuery(SQLOperation.java:257)
2020-05-08T09:40:02.2066729Z at org.apache.hive.service.cli.operation.SQLOperation.runInternal(SQLOperation.java:293)
2020-05-08T09:40:02.2067415Z at org.apache.hive.service.cli.operation.Operation.run(Operation.java:320)
2020-05-08T09:40:02.2068080Z at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:530)
2020-05-08T09:40:02.2068798Z at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatement(HiveSessionImpl.java:500)
2020-05-08T09:40:02.2069312Z at org.apache.hive.service.cli.CLIService.executeStatement(CLIService.java:265)
2020-05-08T09:40:02.2069907Z at com.klarna.hiverunner.HiveServerContainer.executeStatement(HiveServerContainer.java:116)
2020-05-08T09:40:02.2070342Z ... 35 more
2020-05-08T09:40:02.2070713Z Caused by: org.apache.hadoop.hive.ql.metadata.HiveException: Database db1 already exists
2020-05-08T09:40:02.2071379Z at org.apache.hadoop.hive.ql.exec.DDLTask.createDatabase(DDLTask.java:4247)
2020-05-08T09:40:02.2071954Z at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:319)
2020-05-08T09:40:02.2072449Z at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:199)
2020-05-08T09:40:02.2073014Z at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:100)
2020-05-08T09:40:02.2073720Z at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:2183)
2020-05-08T09:40:02.2074206Z at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1839)
2020-05-08T09:40:02.2074833Z at org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:1526)
2020-05-08T09:40:02.2075300Z at org.apache.hadoop.hive.ql.Driver.run(Driver.java:1237)
2020-05-08T09:40:02.2075837Z at org.apache.hadoop.hive.ql.Driver.run(Driver.java:1232)
2020-05-08T09:40:02.2076320Z at org.apache.hive.service.cli.operation.SQLOperation.runQuery(SQLOperation.java:255)
2020-05-08T09:40:02.2076713Z ... 41 more
2020-05-08T09:40:02.2077221Z Caused by: AlreadyExistsException(message:Database db1 already exists)
2020-05-08T09:40:02.2078000Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result$create_database_resultStandardScheme.read(ThriftHiveMetastore.java:26487)
2020-05-08T09:40:02.2078840Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result$create_database_resultStandardScheme.read(ThriftHiveMetastore.java:26473)
2020-05-08T09:40:02.2079803Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result.read(ThriftHiveMetastore.java:26407)
2020-05-08T09:40:02.2080296Z at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
2020-05-08T09:40:02.2080897Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_create_database(ThriftHiveMetastore.java:749)
2020-05-08T09:40:02.2081643Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.create_database(ThriftHiveMetastore.java:736)
2020-05-08T09:40:02.2082363Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createDatabase(HiveMetaStoreClient.java:727)
2020-05-08T09:40:02.2082848Z at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source)
2020-05-08T09:40:02.2083299Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2083946Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2084542Z at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:173)
2020-05-08T09:40:02.2084952Z at com.sun.proxy.$Proxy33.createDatabase(Unknown Source)
2020-05-08T09:40:02.2085384Z at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source)
2020-05-08T09:40:02.2086078Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2086655Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2087354Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient$SynchronizedHandler.invoke(HiveMetaStoreClient.java:2330)
2020-05-08T09:40:02.2087790Z at com.sun.proxy.$Proxy33.createDatabase(Unknown Source)
2020-05-08T09:40:02.2088356Z at org.apache.hadoop.hive.ql.metadata.Hive.createDatabase(Hive.java:427)
2020-05-08T09:40:02.2088784Z at org.apache.hadoop.hive.ql.exec.DDLTask.createDatabase(DDLTask.java:4243)
2020-05-08T09:40:02.2089306Z ... 50 more
2020-05-08T09:40:02.2089426Z
2020-05-08T09:40:02.2089939Z [ERROR] testUpdatePartitionSD(org.apache.flink.connectors.hive.TableEnvHiveConnectorTest)  Time elapsed: 0.015 s  <<< ERROR!
2020-05-08T09:40:02.2090950Z java.lang.IllegalArgumentException: Failed to executeQuery Hive query create database db1: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.2091981Z at com.klarna.hiverunner.HiveServerContainer.executeStatement(HiveServerContainer.java:143)
2020-05-08T09:40:02.2092712Z at com.klarna.hiverunner.builder.HiveShellBase.executeStatementsWithCommandShellEmulation(HiveShellBase.java:121)
2020-05-08T09:40:02.2093480Z at com.klarna.hiverunner.builder.HiveShellBase.executeScriptWithCommandShellEmulation(HiveShellBase.java:110)
2020-05-08T09:40:02.2094185Z at com.klarna.hiverunner.builder.HiveShellBase.execute(HiveShellBase.java:129)
2020-05-08T09:40:02.2094909Z at org.apache.flink.connectors.hive.TableEnvHiveConnectorTest.testUpdatePartitionSD(TableEnvHiveConnectorTest.java:588)
2020-05-08T09:40:02.2095525Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-05-08T09:40:02.2095998Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-05-08T09:40:02.2096642Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2097088Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2097619Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-05-08T09:40:02.2098340Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-05-08T09:40:02.2098795Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-05-08T09:40:02.2099326Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-05-08T09:40:02.2099978Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runTestMethod(FlinkStandaloneHiveRunner.java:169)
2020-05-08T09:40:02.2100828Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:154)
2020-05-08T09:40:02.2101591Z at org.apache.flink.connectors.hive.FlinkStandaloneHiveRunner.runChild(FlinkStandaloneHiveRunner.java:92)
2020-05-08T09:40:02.2102040Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-05-08T09:40:02.2102668Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-05-08T09:40:02.2103233Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-05-08T09:40:02.2103755Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-05-08T09:40:02.2104461Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-05-08T09:40:02.2105023Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-05-08T09:40:02.2105600Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.2106187Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.2106792Z at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-05-08T09:40:02.2107217Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-05-08T09:40:02.2107586Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-05-08T09:40:02.2108205Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-05-08T09:40:02.2108794Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-05-08T09:40:02.2109434Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-05-08T09:40:02.2109943Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-05-08T09:40:02.2110695Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-05-08T09:40:02.2111342Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-05-08T09:40:02.2111801Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-05-08T09:40:02.2112443Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-05-08T09:40:02.2113300Z Caused by: org.apache.hive.service.cli.HiveSQLException: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db1 already exists
2020-05-08T09:40:02.2114079Z at org.apache.hive.service.cli.operation.Operation.toSQLException(Operation.java:380)
2020-05-08T09:40:02.2114738Z at org.apache.hive.service.cli.operation.SQLOperation.runQuery(SQLOperation.java:257)
2020-05-08T09:40:02.2115208Z at org.apache.hive.service.cli.operation.SQLOperation.runInternal(SQLOperation.java:293)
2020-05-08T09:40:02.2115635Z at org.apache.hive.service.cli.operation.Operation.run(Operation.java:320)
2020-05-08T09:40:02.2116251Z at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:530)
2020-05-08T09:40:02.2117029Z at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatement(HiveSessionImpl.java:500)
2020-05-08T09:40:02.2117612Z at org.apache.hive.service.cli.CLIService.executeStatement(CLIService.java:265)
2020-05-08T09:40:02.2118212Z at com.klarna.hiverunner.HiveServerContainer.executeStatement(HiveServerContainer.java:116)
2020-05-08T09:40:02.2118692Z ... 34 more
2020-05-08T09:40:02.2119010Z Caused by: org.apache.hadoop.hive.ql.metadata.HiveException: Database db1 already exists
2020-05-08T09:40:02.2119697Z at org.apache.hadoop.hive.ql.exec.DDLTask.createDatabase(DDLTask.java:4247)
2020-05-08T09:40:02.2120268Z at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:319)
2020-05-08T09:40:02.2120643Z at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:199)
2020-05-08T09:40:02.2121352Z at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:100)
2020-05-08T09:40:02.2121812Z at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:2183)
2020-05-08T09:40:02.2122461Z at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1839)
2020-05-08T09:40:02.2122824Z at org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:1526)
2020-05-08T09:40:02.2123422Z at org.apache.hadoop.hive.ql.Driver.run(Driver.java:1237)
2020-05-08T09:40:02.2123756Z at org.apache.hadoop.hive.ql.Driver.run(Driver.java:1232)
2020-05-08T09:40:02.2124548Z at org.apache.hive.service.cli.operation.SQLOperation.runQuery(SQLOperation.java:255)
2020-05-08T09:40:02.2125000Z ... 40 more
2020-05-08T09:40:02.2125286Z Caused by: AlreadyExistsException(message:Database db1 already exists)
2020-05-08T09:40:02.2125956Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result$create_database_resultStandardScheme.read(ThriftHiveMetastore.java:26487)
2020-05-08T09:40:02.2126801Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result$create_database_resultStandardScheme.read(ThriftHiveMetastore.java:26473)
2020-05-08T09:40:02.2127553Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$create_database_result.read(ThriftHiveMetastore.java:26407)
2020-05-08T09:40:02.2128061Z at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
2020-05-08T09:40:02.2128553Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_create_database(ThriftHiveMetastore.java:749)
2020-05-08T09:40:02.2129172Z at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.create_database(ThriftHiveMetastore.java:736)
2020-05-08T09:40:02.2129821Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createDatabase(HiveMetaStoreClient.java:727)
2020-05-08T09:40:02.2130291Z at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source)
2020-05-08T09:40:02.2130753Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2131444Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2131903Z at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:173)
2020-05-08T09:40:02.2132399Z at com.sun.proxy.$Proxy33.createDatabase(Unknown Source)
2020-05-08T09:40:02.2132829Z at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source)
2020-05-08T09:40:02.2133338Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-05-08T09:40:02.2133848Z at java.lang.reflect.Method.invoke(Method.java:498)
2020-05-08T09:40:02.2134353Z at org.apache.hadoop.hive.metastore.HiveMetaStoreClient$SynchronizedHandler.invoke(HiveMetaStoreClient.java:2330)
2020-05-08T09:40:02.2134876Z at com.sun.proxy.$Proxy33.createDatabase(Unknown Source)
2020-05-08T09:40:02.2135338Z at org.apache.hadoop.hive.ql.metadata.Hive.createDatabase(Hive.java:427)
2020-05-08T09:40:02.2135847Z at org.apache.hadoop.hive.ql.exec.DDLTask.createDatabase(DDLTask.java:4243)
2020-05-08T09:40:02.2136195Z ... 49 more
2020-05-08T09:40:02.2136313Z
2020-05-08T09:40:03.2246042Z [INFO] Running org.apache.flink.connectors.hive.HiveDialectTest
2020-05-08T09:40:16.1437654Z [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.914 s - in org.apache.flink.connectors.hive.HiveDialectTest
2020-05-08T09:40:16.5569091Z [INFO]
2020-05-08T09:40:16.5569441Z [INFO] Results:
2020-05-08T09:40:16.5569645Z [INFO]
2020-05-08T09:40:16.5569962Z [ERROR] Errors:
2020-05-08T09:40:16.5571473Z [ERROR]   HiveTableSinkTest.testInsertIntoNonPartitionTable:91->createHiveDestTable:233->createHiveDestTable:221 » TableAlreadyExist
2020-05-08T09:40:16.5572957Z [ERROR]   HiveTableSinkTest.testWriteComplexType:143 » Execution org.apache.flink.runtim...
2020-05-08T09:40:16.5573995Z [ERROR]   TableEnvHiveConnectorTest.testDefaultPartitionName:106 » Execution org.apache....
2020-05-08T09:40:16.5574692Z [ERROR]   TableEnvHiveConnectorTest.testDifferentFormats:135->readWriteFormat:142 » IllegalArgument
2020-05-08T09:40:16.5575454Z [ERROR]   TableEnvHiveConnectorTest.testInsertOverwrite:238 » IllegalArgument Failed to ...
2020-05-08T09:40:16.5576562Z [ERROR]   TableEnvHiveConnectorTest.testUpdatePartitionSD:588 » IllegalArgument Failed t...
{code}
instance: [https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_apis/build/builds/806/logs/127]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Free forum by Nabble Edit this page