This is an automated email from the ASF dual-hosted git repository.

lirui pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new ea3d085  [FLINK-23096][Connectors/Hive] Optimize the SessionState 
exception capture to print out the correct and useful information
ea3d085 is described below

commit ea3d085f6b19b6dfb36462650344229c9a3ca70b
Author: shizhengchao <shizhengc...@outlook.com>
AuthorDate: Thu Jun 24 10:11:58 2021 +0800

    [FLINK-23096][Connectors/Hive] Optimize the SessionState exception capture 
to print out the correct and useful information
    
    This closes #16259
---
 .../java/org/apache/flink/table/planner/delegation/hive/HiveParser.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java
 
b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java
index d93cbc0..897bdb8 100644
--- 
a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java
+++ 
b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java
@@ -384,7 +384,7 @@ public class HiveParser extends ParserImpl {
                     FileSystem fs = path.getFileSystem(hiveConf);
                     fs.delete(path, true);
                 }
-            } catch (IOException e) {
+            } catch (Exception e) {
                 LOG.warn("Error closing SessionState", e);
             }
         }

Reply via email to