diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java index 37860944b..17447a102 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java @@ -57,10 +57,10 @@ public class AnalysisServerDriver extends Configured implements Tool { conf.set("hbase.zookeeper.quorum", Config.HBase.ZK_QUORUM); conf.set("hbase.zookeeper.property.clientPort", Config.HBase.ZK_CLIENT_PORT); //-XX:+UseParallelGC -XX:ParallelGCThreads=4 -XX:GCTimeRatio=10 -XX:YoungGenerationSizeIncrement=20 -XX:TenuredGenerationSizeIncrement=20 -XX:AdaptiveSizeDecrementScaleFactor=2 - conf.set("mapred.child.java.opts",Config.MapReduce.java_opts); + conf.set("mapred.child.java.opts",Config.MapReduce.JAVA_OPTS); String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs(); if (otherArgs.length != 2) { - System.err.println("Usage: AnalysisServer yyyy-MM-dd/HH:mm:ss yyyy-MM-dd/HH:mm:ss"); + System.err.println("Usage: com.ai.cloud.skywalking.analysis.AnalysisServerDriver yyyy-MM-dd/HH:mm:ss yyyy-MM-dd/HH:mm:ss"); System.exit(2); } diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/config/Config.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/config/Config.java index 01df2cabe..65a11b6cb 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/config/Config.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/config/Config.java @@ -31,6 +31,6 @@ public class Config { } public static class MapReduce{ - public static String java_opts = "-Xmx200m"; + public static String JAVA_OPTS = "-Xmx200m"; } } diff --git a/skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/01.truncateHBaseTable.md b/skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/01.truncateHBaseTable.md new file mode 100644 index 000000000..6c56084ae --- /dev/null +++ b/skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/01.truncateHBaseTable.md @@ -0,0 +1,9 @@ +```sql +truncate "sw-chain-1day-summary" +truncate "sw-chain-1hour-summary" +truncate "sw-chain-1min-summary" +truncate "sw-chain-1month-summary" +truncate "sw-chain-detail" +truncate "sw-treeId-cid-mapping" +truncate "sw-traceId-cid-mapping" +``` \ No newline at end of file diff --git a/skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/02.scan4ColumnValue.md b/skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/02.scan4ColumnValue.md new file mode 100644 index 000000000..d3581f1de --- /dev/null +++ b/skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/02.scan4ColumnValue.md @@ -0,0 +1,13 @@ +* 查询某一张表中的某一列等于某一个值(比如sw-treeId-cid-mapping,sw-traceId-cid-mapping) + +```java +import org.apache.hadoop.hbase.util.Bytes; +import org.apache.hadoop.hbase.filter.SingleColumnValueFilter; +import org.apache.hadoop.hbase.filter.BinaryComparator; +import org.apache.hadoop.hbase.filter.CompareFilter; +import org.apache.hadoop.hbase.filter. Filter; +scan 'sw-chain-info', { FILTER +=>SingleColumnValueFilter.new(Bytes.toBytes('trace_info'),Bytes.toBytes('cid'), +CompareFilter::CompareOp.valueOf('EQUAL'), +BinaryComparator.new(Bytes.toBytes('CID_B4CAEE3953B3C0DBD7A43656B2EEE345')))} +``` \ No newline at end of file