IGNITE-2539 fix code version pre 1.8 now 1.7

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

Branch: refs/heads/ignite-3727-2
Commit: ecd3d93e69e4ffaceec49052181ad7a80b321152
Parents: 7e60424
Author: DmitriyGovorukhin <[email protected]>
Authored: Thu Sep 8 19:08:32 2016 +0300
Committer: DmitriyGovorukhin <[email protected]>
Committed: Thu Sep 8 19:08:32 2016 +0300

----------------------------------------------------------------------
 .../affinity/bugreproduce/IssuesIGNITE2539ReproduceTest.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/ecd3d93e/modules/core/src/test/java/org/apache/ignite/cache/affinity/bugreproduce/IssuesIGNITE2539ReproduceTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/cache/affinity/bugreproduce/IssuesIGNITE2539ReproduceTest.java
 
b/modules/core/src/test/java/org/apache/ignite/cache/affinity/bugreproduce/IssuesIGNITE2539ReproduceTest.java
index c39ebf0..72854f7 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/cache/affinity/bugreproduce/IssuesIGNITE2539ReproduceTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/cache/affinity/bugreproduce/IssuesIGNITE2539ReproduceTest.java
@@ -145,9 +145,9 @@ public class IssuesIGNITE2539ReproduceTest extends 
GridCommonAbstractTest {
 
         for (int j = 0; j < itr; j++) {
 
-            AtomicReference<Throwable> exc = new AtomicReference<>();
+            final AtomicReference<Throwable> exc = new AtomicReference<>();
 
-            AtomicBoolean asyncRun = new AtomicBoolean(true);
+            final AtomicBoolean asyncRun = new AtomicBoolean(true);
 
             for (Thread worker : getExchangeWorkerThread()) {
                 worker.setUncaughtExceptionHandler(new 
Thread.UncaughtExceptionHandler() {

Reply via email to