ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [16/20] ignite git commit: IGNITE-2355 Fixed the test HadoopClientProtocolMultipleServersSelfTest. Clear connection poll before and after the test
Date Fri, 28 Oct 2016 12:17:47 GMT
IGNITE-2355 Fixed the test HadoopClientProtocolMultipleServersSelfTest. Clear connection poll
before and after  the test


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/551a4dfa
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/551a4dfa
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/551a4dfa

Branch: refs/heads/ignite-4111
Commit: 551a4dfae6169a07a5e28f9b266f90311f3216b7
Parents: 7ed2bb7
Author: tledkov-gridgain <tledkov@gridgain.com>
Authored: Fri Oct 21 15:25:57 2016 +0500
Committer: tledkov-gridgain <tledkov@gridgain.com>
Committed: Fri Oct 21 15:25:57 2016 +0500

----------------------------------------------------------------------
 ...oopClientProtocolMultipleServersSelfTest.java | 19 +++++++++++++++++--
 1 file changed, 17 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/551a4dfa/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/client/HadoopClientProtocolMultipleServersSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/client/HadoopClientProtocolMultipleServersSelfTest.java
b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/client/HadoopClientProtocolMultipleServersSelfTest.java
index 51b6164..d6e0743 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/client/HadoopClientProtocolMultipleServersSelfTest.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/client/HadoopClientProtocolMultipleServersSelfTest.java
@@ -40,6 +40,7 @@ import org.apache.hadoop.mapreduce.Reducer;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
 import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
+import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.IgniteFileSystem;
 import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.hadoop.mapreduce.IgniteHadoopClientProtocolProvider;
@@ -81,6 +82,22 @@ public class HadoopClientProtocolMultipleServersSelfTest extends HadoopAbstractS
     @Override protected void afterTest() throws Exception {
         stopAllGrids();
 
+        clearConnectionMap();
+
+        super.afterTest();
+    }
+
+    /** {@inheritDoc} */
+    @Override protected void beforeTest() throws Exception {
+        super.beforeTest();
+
+        clearConnectionMap();
+    }
+
+    /**
+     * @throws IgniteCheckedException If failed.
+     */
+    private void clearConnectionMap() throws IgniteCheckedException {
         ConcurrentHashMap<String, IgniteInternalFuture<GridClient>> cliMap =
             GridTestUtils.getFieldValue(IgniteHadoopClientProtocolProvider.class, "cliMap");
 
@@ -88,8 +105,6 @@ public class HadoopClientProtocolMultipleServersSelfTest extends HadoopAbstractS
             fut.get().close();
 
         cliMap.clear();
-
-        super.afterTest();
     }
 
     /** {@inheritDoc} */


Mime
View raw message