storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/3] storm git commit: [STORM-2189] RAS_Node::freeCPU outputs incorrect info
Date Wed, 09 Nov 2016 00:36:16 GMT
Repository: storm
Updated Branches:
  refs/heads/master 6dc6407a0 -> 6bdad214e


[STORM-2189] RAS_Node::freeCPU outputs incorrect info

CPU trying to free should be ``_availCPU + amount`` rather than ``_availMemory + amount``.

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

Branch: refs/heads/master
Commit: 7f0479fba3c7c97288a8cadc856cfd1dfda3ca4a
Parents: 32c83d8
Author: Li Wang <wangli1426@gmail.com>
Authored: Mon Nov 7 11:03:05 2016 +0800
Committer: GitHub <noreply@github.com>
Committed: Mon Nov 7 11:03:05 2016 +0800

----------------------------------------------------------------------
 .../src/jvm/org/apache/storm/scheduler/resource/RAS_Node.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/7f0479fb/storm-core/src/jvm/org/apache/storm/scheduler/resource/RAS_Node.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/scheduler/resource/RAS_Node.java b/storm-core/src/jvm/org/apache/storm/scheduler/resource/RAS_Node.java
index 0bb36e8..f3ffa45 100644
--- a/storm-core/src/jvm/org/apache/storm/scheduler/resource/RAS_Node.java
+++ b/storm-core/src/jvm/org/apache/storm/scheduler/resource/RAS_Node.java
@@ -250,7 +250,7 @@ public class RAS_Node {
     private void freeCPU(double amount) {
         LOG.debug("freeing {} CPU on node...avail CPU: {}", amount, getHostname(), _availCPU);
         if ((_availCPU + amount) > getTotalCpuResources()) {
-            LOG.warn("Freeing more CPU than there exists! CPU trying to free: {} Total CPU
on Node: {}", (_availMemory + amount), getTotalCpuResources());
+            LOG.warn("Freeing more CPU than there exists! CPU trying to free: {} Total CPU
on Node: {}", (_availCPU + amount), getTotalCpuResources());
             return;
         }
         _availCPU += amount;


Mime
View raw message