You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/06/24 07:05:09 UTC
[31/50] kylin git commit: KYLIN-1741 Reload metadata before diagnosis
KYLIN-1741 Reload metadata before diagnosis
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5fd26125
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5fd26125
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5fd26125
Branch: refs/heads/stream_m1
Commit: 5fd26125b08e080fcc2d4734b665d4a5994e43d4
Parents: b361d8a
Author: lidongsjtu <li...@apache.org>
Authored: Wed Jun 22 14:16:26 2016 +0800
Committer: lidongsjtu <li...@apache.org>
Committed: Wed Jun 22 14:16:32 2016 +0800
----------------------------------------------------------------------
.../apache/kylin/tool/KylinLogExtractor.java | 24 ++++++++++++++++++++
1 file changed, 24 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/5fd26125/tool/src/main/java/org/apache/kylin/tool/KylinLogExtractor.java
----------------------------------------------------------------------
diff --git a/tool/src/main/java/org/apache/kylin/tool/KylinLogExtractor.java b/tool/src/main/java/org/apache/kylin/tool/KylinLogExtractor.java
index 2e270ba..a6d9901 100644
--- a/tool/src/main/java/org/apache/kylin/tool/KylinLogExtractor.java
+++ b/tool/src/main/java/org/apache/kylin/tool/KylinLogExtractor.java
@@ -28,6 +28,10 @@ import org.apache.commons.cli.OptionBuilder;
import org.apache.commons.io.FileUtils;
import org.apache.kylin.common.KylinConfig;
import org.apache.kylin.common.util.OptionsHelper;
+import org.apache.kylin.cube.CubeDescManager;
+import org.apache.kylin.cube.CubeManager;
+import org.apache.kylin.metadata.MetadataManager;
+import org.apache.kylin.metadata.project.ProjectManager;
import org.apache.kylin.tool.util.ToolUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -42,15 +46,35 @@ public class KylinLogExtractor extends AbstractInfoExtractor {
@SuppressWarnings("static-access")
private static final Option OPTION_LOG_PERIOD = OptionBuilder.withArgName("logPeriod").hasArg().isRequired(false).withDescription("specify how many days of kylin logs to extract. Default " + DEFAULT_LOG_PERIOD + ".").create("logPeriod");
+ KylinConfig config;
+
public KylinLogExtractor() {
super();
packageType = "logs";
options.addOption(OPTION_LOG_PERIOD);
+
+ config = KylinConfig.getInstanceFromEnv();
+ }
+
+ private void beforeExtract() {
+ // reload metadata before extract diagnosis info
+ logger.info("Start to reload metadata from diagnosis.");
+
+ CubeManager.clearCache();
+ CubeManager.getInstance(config);
+ CubeDescManager.clearCache();
+ CubeDescManager.getInstance(config);
+ MetadataManager.clearCache();
+ MetadataManager.getInstance(config);
+ ProjectManager.clearCache();
+ ProjectManager.getInstance(config);
}
@Override
protected void executeExtract(OptionsHelper optionsHelper, File exportDir) throws Exception {
+ beforeExtract();
+
int logPeriod = optionsHelper.hasOption(OPTION_LOG_PERIOD) ? Integer.valueOf(optionsHelper.getOptionValue(OPTION_LOG_PERIOD)) : DEFAULT_LOG_PERIOD;
if (logPeriod < 1) {