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:10 GMT
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 841feafe9 -> 08b0074c4


[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/8d1b61a5
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8d1b61a5
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8d1b61a5

Branch: refs/heads/1.x-branch
Commit: 8d1b61a5f83b9bdf3ece2e94b2aaaf46da040e5a
Parents: 841feaf
Author: Li Wang <wangli1426@gmail.com>
Authored: Mon Nov 7 11:03:05 2016 +0800
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Wed Nov 9 09:34:30 2016 +0900

----------------------------------------------------------------------
 .../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/8d1b61a5/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