diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java index f24bcbd8a2..057033175f 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java @@ -158,8 +158,9 @@ private Long incrementalDump(Path dumpRoot, DumpMetaData dmd, Path cmRoot) throw new EventBoundaryFilter(work.eventFrom, work.eventTo), new MessageFormatFilter(MessageFactory.getInstance().getMessageFormat())); + Hive db = getHive(); EventUtils.MSClientNotificationFetcher evFetcher - = new EventUtils.MSClientNotificationFetcher(getHive()); + = new EventUtils.MSClientNotificationFetcher(db); EventUtils.NotificationEventIterator evIter = new EventUtils.NotificationEventIterator( evFetcher, work.eventFrom, work.maxEventLimit(), evFilter); @@ -175,7 +176,7 @@ private Long incrementalDump(Path dumpRoot, DumpMetaData dmd, Path cmRoot) throw NotificationEvent ev = evIter.next(); lastReplId = ev.getEventId(); Path evRoot = new Path(dumpRoot, String.valueOf(lastReplId)); - dumpEvent(ev, evRoot, cmRoot); + dumpEvent(ev, evRoot, cmRoot, db); } replLogger.endLog(lastReplId.toString()); @@ -193,11 +194,11 @@ private Long incrementalDump(Path dumpRoot, DumpMetaData dmd, Path cmRoot) throw return lastReplId; } - private void dumpEvent(NotificationEvent ev, Path evRoot, Path cmRoot) throws Exception { + private void dumpEvent(NotificationEvent ev, Path evRoot, Path cmRoot, Hive db) throws Exception { EventHandler.Context context = new EventHandler.Context( evRoot, cmRoot, - getHive(), + db, conf, getNewEventOnlyReplicationSpec(ev.getEventId()), work.dbNameOrPattern,