ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject ignite git commit: Removed sleep from shuffle job thread.
Date Mon, 21 Nov 2016 09:16:02 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1.6.10-hadoop-debug 797841da9 -> c2bff238e


Removed sleep from shuffle job thread.


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

Branch: refs/heads/ignite-1.6.10-hadoop-debug
Commit: c2bff238eaca73274b52bf18453e155dbd450a51
Parents: 797841d
Author: devozerov <vozerov@gridgain.com>
Authored: Mon Nov 21 12:15:52 2016 +0300
Committer: devozerov <vozerov@gridgain.com>
Committed: Mon Nov 21 12:15:52 2016 +0300

----------------------------------------------------------------------
 .../internal/processors/hadoop/shuffle/HadoopShuffleJob.java       | 2 --
 1 file changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/c2bff238/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/shuffle/HadoopShuffleJob.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/shuffle/HadoopShuffleJob.java
b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/shuffle/HadoopShuffleJob.java
index b940c72..1411b36 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/shuffle/HadoopShuffleJob.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/shuffle/HadoopShuffleJob.java
@@ -175,8 +175,6 @@ public class HadoopShuffleJob<T> implements AutoCloseable {
                 @Override protected void body() throws InterruptedException {
                     try {
                         while (!isCancelled()) {
-                            Thread.sleep(5);
-
                             collectUpdatesAndSend(false);
                         }
                     }


Mime
View raw message