Loading skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTree.java +1 −1 Original line number Diff line number Diff line Loading @@ -69,7 +69,7 @@ public class CallChainTree { } } public void saveToHbase() throws IOException { public void saveToHbase() throws IOException, InterruptedException { List<Put> chainInfoPuts = new ArrayList<Put>(); for (Map.Entry<String, ChainInfo> entry : combineChains.entrySet()) { Put put = new Put(entry.getKey().getBytes()); Loading skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java +1 −1 Original line number Diff line number Diff line Loading @@ -67,7 +67,7 @@ public class CallChainTreeNode { return new GsonBuilder().excludeFieldsWithoutExposeAnnotation().create().toJson(this); } public void saveSummaryResultToHBase() { public void saveSummaryResultToHBase() throws IOException, InterruptedException { List<Put> puts = new ArrayList<Put>(); for (Map.Entry<String, ChainNodeSpecificMinSummary> entry : chainNodeContainer.entrySet()) { Put put = new Put(entry.getKey().getBytes()); Loading Loading
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTree.java +1 −1 Original line number Diff line number Diff line Loading @@ -69,7 +69,7 @@ public class CallChainTree { } } public void saveToHbase() throws IOException { public void saveToHbase() throws IOException, InterruptedException { List<Put> chainInfoPuts = new ArrayList<Put>(); for (Map.Entry<String, ChainInfo> entry : combineChains.entrySet()) { Put put = new Put(entry.getKey().getBytes()); Loading
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java +1 −1 Original line number Diff line number Diff line Loading @@ -67,7 +67,7 @@ public class CallChainTreeNode { return new GsonBuilder().excludeFieldsWithoutExposeAnnotation().create().toJson(this); } public void saveSummaryResultToHBase() { public void saveSummaryResultToHBase() throws IOException, InterruptedException { List<Put> puts = new ArrayList<Put>(); for (Map.Entry<String, ChainNodeSpecificMinSummary> entry : chainNodeContainer.entrySet()) { Put put = new Put(entry.getKey().getBytes()); Loading