HDFS-14016. [SBN read] ObserverReadProxyProvider should enable observer read by default. Contributed by Chen Liang.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/1a9ba961 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/1a9ba961 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/1a9ba961 Branch: refs/heads/trunk Commit: 1a9ba9616a7e2279dcd5a30190b289945713054e Parents: 8c49135 Author: Chao Sun <[email protected]> Authored: Wed Oct 31 11:22:02 2018 -0700 Committer: Konstantin V Shvachko <[email protected]> Committed: Mon Dec 24 09:34:01 2018 -0800 ---------------------------------------------------------------------- .../hadoop/hdfs/server/namenode/ha/ObserverReadProxyProvider.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/1a9ba961/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/ObserverReadProxyProvider.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/ObserverReadProxyProvider.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/ObserverReadProxyProvider.java index 87ca718..17bad65 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/ObserverReadProxyProvider.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/ObserverReadProxyProvider.java @@ -141,6 +141,8 @@ public class ObserverReadProxyProvider<T extends ClientProtocol> ObserverReadInvocationHandler.class.getClassLoader(), new Class<?>[] { xface }, new ObserverReadInvocationHandler()); combinedProxy = new ProxyInfo<>(wrappedProxy, combinedInfo.toString()); + // TODO : make this configurable or remove this variable + this.observerReadEnabled = true; } public AlignmentContext getAlignmentContext() { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
