Repository: sentry Updated Branches: refs/heads/master 1860b946b -> f3e93a475
SENTRY-2059: Fix the tests to use transaction listeners for handling HMS Notifications. (Kalyan Kumar Kalvagadda, reviewed by Sergio Pena) Project: http://git-wip-us.apache.org/repos/asf/sentry/repo Commit: http://git-wip-us.apache.org/repos/asf/sentry/commit/f3e93a47 Tree: http://git-wip-us.apache.org/repos/asf/sentry/tree/f3e93a47 Diff: http://git-wip-us.apache.org/repos/asf/sentry/diff/f3e93a47 Branch: refs/heads/master Commit: f3e93a4758266bab77d6359bc2f7c8c7ddfc1b32 Parents: 1860b94 Author: Kalyan Kumar Kalvagadda <kkal...@cloudera.com> Authored: Tue Nov 21 12:53:03 2017 -0600 Committer: Kalyan Kumar Kalvagadda <kkal...@cloudera.com> Committed: Tue Nov 21 12:53:03 2017 -0600 ---------------------------------------------------------------------- .../apache/sentry/tests/e2e/hdfs/TestHDFSIntegrationBase.java | 2 +- .../tests/e2e/hive/AbstractTestWithStaticConfiguration.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sentry/blob/f3e93a47/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hdfs/TestHDFSIntegrationBase.java ---------------------------------------------------------------------- diff --git a/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hdfs/TestHDFSIntegrationBase.java b/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hdfs/TestHDFSIntegrationBase.java index 25a678b..d9aec8b 100644 --- a/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hdfs/TestHDFSIntegrationBase.java +++ b/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hdfs/TestHDFSIntegrationBase.java @@ -586,7 +586,7 @@ public abstract class TestHDFSIntegrationBase { hiveConf.set("hive.metastore.authorization.storage.checks", "true"); hiveConf.set("hive.metastore.uris", "thrift://localhost:" + hmsPort); hiveConf.set("hive.metastore.pre.event.listeners", "org.apache.sentry.binding.metastore.MetastoreAuthzBinding"); - hiveConf.set("hive.metastore.event.listeners", "org.apache.sentry.binding.metastore.SentryMetastorePostEventListenerNotificationLog"); + hiveConf.set("hive.metastore.transactional.event.listeners", "org.apache.sentry.binding.metastore.SentryMetastorePostEventListenerNotificationLog"); hiveConf.set("hcatalog.message.factory.impl.json", "org.apache.sentry.binding.metastore.messaging.json.SentryJSONMessageFactory"); hiveConf.set("hive.security.authorization.task.factory", "org.apache.sentry.binding.hive.SentryHiveAuthorizationTaskFactoryImpl"); hiveConf.set("hive.server2.session.hook", "org.apache.sentry.binding.hive.HiveAuthzBindingSessionHook"); http://git-wip-us.apache.org/repos/asf/sentry/blob/f3e93a47/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/AbstractTestWithStaticConfiguration.java ---------------------------------------------------------------------- diff --git a/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/AbstractTestWithStaticConfiguration.java b/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/AbstractTestWithStaticConfiguration.java index a6e7356..708733e 100644 --- a/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/AbstractTestWithStaticConfiguration.java +++ b/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/AbstractTestWithStaticConfiguration.java @@ -516,10 +516,10 @@ public abstract class AbstractTestWithStaticConfiguration extends RulesForE2ETes if (setMetastoreListener) { LOGGER.info("setMetastoreListener is enabled"); if (useDbNotificationListener) { - properties.put(HiveConf.ConfVars.METASTORE_EVENT_LISTENERS.varname, + properties.put(HiveConf.ConfVars.METASTORE_TRANSACTIONAL_EVENT_LISTENERS.varname, "org.apache.hive.hcatalog.listener.DbNotificationListener"); } else { - properties.put(HiveConf.ConfVars.METASTORE_EVENT_LISTENERS.varname, + properties.put(HiveConf.ConfVars.METASTORE_TRANSACTIONAL_EVENT_LISTENERS.varname, SentryMetastorePostEventListenerNotificationLog.class.getName()); properties.put("hcatalog.message.factory.impl.json", "org.apache.sentry.binding.metastore.messaging.json.SentryJSONMessageFactory");
