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); } }