lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1980] Optimize the code to prevent other exceptions from causing resources not to be closed (#3038)

Browse Source 
Co-authored-by: wei.zhang2 <wei.zhang2@dmall.com>
This commit is contained in:
Wei
2021-06-08 21:58:34 +08:00
committed by GitHub
parent 7261f08507
commit 75d663f65d
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java
View File

@@ -19,7 +19,6 @@
package org.apache.hudi.hive; package org.apache.hudi.hive;
import org.apache.hadoop.hive.metastore.api.FieldSchema; import org.apache.hadoop.hive.metastore.api.FieldSchema;
import org.apache.hadoop.hive.metastore.api.MetaException;
import org.apache.hadoop.hive.metastore.api.Partition; import org.apache.hadoop.hive.metastore.api.Partition;
import org.apache.hadoop.hive.metastore.api.Table; import org.apache.hadoop.hive.metastore.api.Table;
import org.apache.hadoop.hive.metastore.api.Database; import org.apache.hadoop.hive.metastore.api.Database;
@@ -39,7 +38,6 @@ import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.metastore.IMetaStoreClient; import org.apache.hadoop.hive.metastore.IMetaStoreClient;
import org.apache.hadoop.hive.ql.metadata.Hive; import org.apache.hadoop.hive.ql.metadata.Hive;
import org.apache.hadoop.hive.ql.metadata.HiveException;
import org.apache.hadoop.hive.ql.processors.CommandProcessorResponse; import org.apache.hadoop.hive.ql.processors.CommandProcessorResponse;
import org.apache.hadoop.hive.ql.session.SessionState; import org.apache.hadoop.hive.ql.session.SessionState;
import org.apache.hudi.sync.common.AbstractSyncHoodieClient; import org.apache.hudi.sync.common.AbstractSyncHoodieClient;
@@ -100,7 +98,7 @@ public class HoodieHiveClient extends AbstractSyncHoodieClient {
this.client = Hive.get(configuration).getMSC(); this.client = Hive.get(configuration).getMSC();
LOG.info(String.format("Time taken to start SessionState and create Driver and client: " LOG.info(String.format("Time taken to start SessionState and create Driver and client: "
+ "%s ms", (timer.endTimer()))); + "%s ms", (timer.endTimer())));
} catch (MetaException | HiveException | IOException e) { } catch (Exception e) {
if (this.sessionState != null) { if (this.sessionState != null) {
try { try {
this.sessionState.close(); this.sessionState.close();