hehuiyuan commented on a change in pull request #15244:
URL: https://github.com/apache/flink/pull/15244#discussion_r596826072
##########
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
##########
@@ -224,7 +225,11 @@ private static HiveConf createHiveConf(
} else {
hadoopConf = getHadoopConfiguration(hadoopConfDir);
}
- if (hadoopConf == null) {
+ if (hadoopConf == null && !isNullOrWhitespaceOnly(hadoopConfDir)) {
+ throw new CatalogException(
+ "Failed to load the hadoop conf from specified path:" +
hadoopConfDir,
+ new FileNotFoundException("Path " + hadoopConfDir + " does
not exist."));
Review comment:
@lirui-apache , ok.
Additional, try to find the paths with configuration files as far as
possible from possiable hadoop conf path.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
