Repository: hadoop Updated Branches: refs/heads/trunk 41b581012 -> d62932c3b
YARN-7032. [ATSv2] NPE while starting hbase co-processor when HBase authorization is enabled. Contributed by Rohith Sharma K S. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d62932c3 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d62932c3 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d62932c3 Branch: refs/heads/trunk Commit: d62932c3b2fcacc81dc1f5048cdeb60fb0d38504 Parents: 41b5810 Author: Sunil G <sun...@apache.org> Authored: Wed Dec 20 11:31:15 2017 +0530 Committer: Sunil G <sun...@apache.org> Committed: Wed Dec 20 11:31:15 2017 +0530 ---------------------------------------------------------------------- .../server/timelineservice/storage/flow/FlowRunCoprocessor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d62932c3/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowRunCoprocessor.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowRunCoprocessor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowRunCoprocessor.java index 359eec9..96a7cf3 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowRunCoprocessor.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow/FlowRunCoprocessor.java @@ -98,7 +98,9 @@ public class FlowRunCoprocessor extends BaseRegionObserver { if ((attributes != null) && (attributes.size() > 0)) { for (Map.Entry<String, byte[]> attribute : attributes.entrySet()) { Tag t = HBaseTimelineStorageUtils.getTagFromAttribute(attribute); - tags.add(t); + if (t != null) { + tags.add(t); + } } byte[] tagByteArray = Tag.fromList(tags); NavigableMap<byte[], List<Cell>> newFamilyMap = new TreeMap<>( --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org