[tez] branch master updated: TEZ-4213: Bound appContext executor capacity using a configurable property (Panagiotis Garefalakis reviewed by Ashutosh Chauhan, Mustafa Iman, Attila Magyar) - addendum checkstyle

[ab...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

abstractdog pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git


The following commit(s) were added to refs/heads/master by this push:
     new 99895f9  TEZ-4213: Bound appContext executor capacity using a configurable property (Panagiotis Garefalakis reviewed by Ashutosh Chauhan, Mustafa Iman, Attila Magyar) - addendum checkstyle
99895f9 is described below

commit 99895f9808170ce64fd1e7c6dfb2e932f4578489
Author: Laszlo Bodor <bo...@gmail.com>
AuthorDate: Tue Aug 25 13:56:57 2020 +0200

    TEZ-4213: Bound appContext executor capacity using a configurable property (Panagiotis Garefalakis reviewed by Ashutosh Chauhan, Mustafa Iman, Attila Magyar) - addendum checkstyle
---
 .../apache/tez/dag/app/dag/TestRootInputInitializerManager.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/dag/TestRootInputInitializerManager.java b/tez-dag/src/test/java/org/apache/tez/dag/app/dag/TestRootInputInitializerManager.java
index 000f077..a197e54 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/dag/TestRootInputInitializerManager.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/dag/TestRootInputInitializerManager.java
@@ -327,15 +327,15 @@ public class TestRootInputInitializerManager {
     List<RootInputInitializerManager.InitializerWrapper> initWrappers =
             rootInputInitializerManager.createInitializerWrappers(inlist);
 
-    int max_thread_size = conf.getInt(TezConfiguration.TEZ_AM_DAG_APPCONTEXT_THREAD_COUNT_LIMIT,
+    int maxThreadSize = conf.getInt(TezConfiguration.TEZ_AM_DAG_APPCONTEXT_THREAD_COUNT_LIMIT,
             TezConfiguration.TEZ_AM_DAG_APPCONTEXT_THREAD_COUNT_LIMIT_DEFAULT);
     ThreadPoolExecutor amThreadPool = am.getContext().getThreadPool();
 
-    rootInputInitializerManager.executor.submit(()
-            -> rootInputInitializerManager.createAndStartInitializing(Collections.emptyList(), initWrappers));
+    rootInputInitializerManager.executor.submit(() -> rootInputInitializerManager
+        .createAndStartInitializing(Collections.emptyList(), initWrappers));
 
     while (am.getContext().getThreadPool().getQueue().size() > 0) {
-      assertTrue(amThreadPool.getPoolSize() <= max_thread_size);
+      assertTrue(amThreadPool.getPoolSize() <= maxThreadSize);
       Thread.sleep(100);
     }
   }