diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java index 2430811..f765d99 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java @@ -10818,14 +10818,14 @@ private void walkASTMarkTABREF(ASTNode ast, Set cteAlias) .applyRowFilterAndColumnMasking(basicPrivObjs); if (needRewritePrivObjs != null && !needRewritePrivObjs.isEmpty()) { for (HivePrivilegeObject privObj : needRewritePrivObjs) { - // We don't support masking/filtering against ACID query at the moment - if (ctx.getIsUpdateDeleteMerge()) { - throw new SemanticException(ErrorMsg.MASKING_FILTERING_ON_ACID_NOT_SUPPORTED, - privObj.getDbname(), privObj.getObjectName()); - } MaskAndFilterInfo info = basicInfos.get(privObj); String replacementText = tableMask.create(privObj, info); if (replacementText != null) { + // We don't support masking/filtering against ACID query at the moment + if (ctx.getIsUpdateDeleteMerge()) { + throw new SemanticException(ErrorMsg.MASKING_FILTERING_ON_ACID_NOT_SUPPORTED, + privObj.getDbname(), privObj.getObjectName()); + } tableMask.setNeedsRewrite(true); tableMask.addTranslation(info.astNode, replacementText); }