checkstyle/license

hbase-client/src/main/java/org/apache/hadoop/hbase/ServerOverloadedException.java

@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.hadoop.hbase;
 
 import org.apache.yetus.audience.InterfaceAudience;

hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java

@@ -46,8 +46,8 @@ public interface Callable<T> {
   public AsyncAdminRequestRetryingCaller(Timer retryTimer, AsyncConnectionImpl conn, int priority,
       long pauseNs, long pauseForServerOverloaded, int maxAttempts, long operationTimeoutNs,
       long rpcTimeoutNs, int startLogErrorsCnt, ServerName serverName, Callable<T> callable) {
-    super(retryTimer, conn, priority, pauseNs, pauseForServerOverloaded, maxAttempts, operationTimeoutNs,
-      rpcTimeoutNs, startLogErrorsCnt);
+    super(retryTimer, conn, priority, pauseNs, pauseForServerOverloaded, maxAttempts,
+      operationTimeoutNs, rpcTimeoutNs, startLogErrorsCnt);
     this.serverName = serverName;
     this.callable = callable;
   }

hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.java

@@ -150,8 +150,9 @@ public int getPriority() {
   }
 
   public AsyncBatchRpcRetryingCaller(Timer retryTimer, AsyncConnectionImpl conn,
-      TableName tableName, List<? extends Row> actions, long pauseNs, long pauseNsForServerOverloaded,
-      int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt) {
+      TableName tableName, List<? extends Row> actions, long pauseNs,
+      long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs,
+      long rpcTimeoutNs, int startLogErrorsCnt) {
     this.retryTimer = retryTimer;
     this.conn = conn;
     this.tableName = tableName;

hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java

@@ -516,8 +516,9 @@ public AdminRequestCallerBuilder<T> priority(int priority) {
 
     public AsyncAdminRequestRetryingCaller<T> build() {
       return new AsyncAdminRequestRetryingCaller<T>(retryTimer, conn, priority, pauseNs,
-        pauseNsForServerOverloaded, maxAttempts, operationTimeoutNs, rpcTimeoutNs, startLogErrorsCnt,
-        checkNotNull(serverName, "serverName is null"), checkNotNull(callable, "action is null"));
+        pauseNsForServerOverloaded, maxAttempts, operationTimeoutNs, rpcTimeoutNs,
+        startLogErrorsCnt, checkNotNull(serverName, "serverName is null"),
+        checkNotNull(callable, "action is null"));
     }
 
     public CompletableFuture<T> call() {

hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java

@@ -799,7 +799,7 @@ public enum OperationStatusCode {
   /**
    * Parameter name for client pause value for special case such as call queue too big, etc.
    * @deprecated Since 2.6.0, will be removed in 4.0.0. Please use
-   * hbase.client.pause.server.overloaded instead.
+   *    hbase.client.pause.server.overloaded instead.
    */
   @Deprecated
   public static final String HBASE_CLIENT_PAUSE_FOR_CQTBE = "hbase.client.pause.cqtbe";
@@ -808,7 +808,8 @@ public enum OperationStatusCode {
    * Parameter name for client pause when server is overloaded, denoted by a
    * subclass of ServerOverloadedException.
    */
-  public static final String HBASE_CLIENT_PAUSE_FOR_SERVER_OVERLOADED = "hbase.client.pause.server.overloaded";
+  public static final String HBASE_CLIENT_PAUSE_FOR_SERVER_OVERLOADED =
+    "hbase.client.pause.server.overloaded";
 
   /**
    * The maximum number of concurrent connections the client will maintain.

hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncClientPauseForServerOverloaded.java

@@ -107,7 +107,7 @@ public OverloadedRpcScheduler(Configuration conf, int handlerCount, int priority
     @Override
     public boolean dispatch(CallRunner callTask) throws InterruptedException {
       if (MODE == FailMode.CALL_QUEUE_TOO_BIG && MODE.shouldFail(callTask)) {
-          return false;
+        return false;
       }
       return super.dispatch(callTask);
     }