From 60d3fbb22b125b06f619c2ff7cdae2b58c1e399a Mon Sep 17 00:00:00 2001 From: "bowen.li" Date: Wed, 5 Jun 2019 14:25:20 -0700 Subject: [PATCH] [hotfix][hive] make HiveCatalog's HiveConf and client wrapper private --- .../java/org/apache/flink/table/catalog/hive/HiveCatalog.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java index 0489757eec77a..00c5f152eb1cb 100644 --- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java +++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java @@ -105,9 +105,9 @@ public class HiveCatalog extends AbstractCatalog { // because Hive's Function object doesn't have properties or other place to store the flag for Flink functions. private static final String FLINK_FUNCTION_PREFIX = "flink:"; - protected final HiveConf hiveConf; + private final HiveConf hiveConf; - protected HiveMetastoreClientWrapper client; + private HiveMetastoreClientWrapper client; public HiveCatalog(String catalogName, String hivemetastoreURI) { this(catalogName, DEFAULT_DB, getHiveConf(hivemetastoreURI));