You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/10/13 10:55:22 UTC
incubator-kylin git commit: minor,
more robust GC before InMemCubeBuilder calculate available system mem
Repository: incubator-kylin
Updated Branches:
refs/heads/2.x-staging e00e5a922 -> e0b8aab84
minor, more robust GC before InMemCubeBuilder calculate available system mem
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/e0b8aab8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/e0b8aab8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/e0b8aab8
Branch: refs/heads/2.x-staging
Commit: e0b8aab84e151192ffbac4ce09a97482dd280b4e
Parents: e00e5a9
Author: Li, Yang <ya...@ebay.com>
Authored: Tue Oct 13 16:55:13 2015 +0800
Committer: Li, Yang <ya...@ebay.com>
Committed: Tue Oct 13 16:55:13 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/cube/inmemcubing/InMemCubeBuilder.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/e0b8aab8/core-cube/src/main/java/org/apache/kylin/cube/inmemcubing/InMemCubeBuilder.java
----------------------------------------------------------------------
diff --git a/core-cube/src/main/java/org/apache/kylin/cube/inmemcubing/InMemCubeBuilder.java b/core-cube/src/main/java/org/apache/kylin/cube/inmemcubing/InMemCubeBuilder.java
index a58f1ef..fa998ff 100644
--- a/core-cube/src/main/java/org/apache/kylin/cube/inmemcubing/InMemCubeBuilder.java
+++ b/core-cube/src/main/java/org/apache/kylin/cube/inmemcubing/InMemCubeBuilder.java
@@ -335,9 +335,17 @@ public class InMemCubeBuilder extends AbstractInMemCubeBuilder {
}
private int getSystemAvailMB() {
+ // GC to be precise on memory left
Runtime.getRuntime().gc();
try {
- Thread.sleep(500);
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ logger.error("", e);
+ }
+ // GC again to be precise on memory left
+ Runtime.getRuntime().gc();
+ try {
+ Thread.sleep(1000);
} catch (InterruptedException e) {
logger.error("", e);
}