STORM-1280 port backtype.storm.daemon.logviewer to java * apply changed API path to integration-test * didn't realize integration accesses logviewer
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/37f9c599 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/37f9c599 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/37f9c599 Branch: refs/heads/master Commit: 37f9c59949a1d8873668934b317e5c1ba20d3599 Parents: f9ed5d4 Author: Jungtaek Lim <[email protected]> Authored: Thu Jul 20 19:51:17 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Thu Jul 20 19:51:17 2017 +0900 ---------------------------------------------------------------------- .../src/test/java/org/apache/storm/st/wrapper/TopoWrap.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/37f9c599/integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java ---------------------------------------------------------------------- diff --git a/integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java b/integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java index af1e1be..a0082a8 100644 --- a/integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java +++ b/integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java @@ -261,8 +261,8 @@ public class TopoWrap { public ExecutorURL(String componentId, String host, int logViewerPort, int executorPort, String topoId) throws MalformedURLException { String sep = "%2F"; //hex of "/" - String viewUrlStr = String.format("http://%s:%s/log?file=";, host, logViewerPort); - String downloadUrlStr = String.format("http://%s:%s/download?file=%%2F";, host, logViewerPort); + String viewUrlStr = String.format("http://%s:%s/api/v1/log?file=";, host, logViewerPort); + String downloadUrlStr = String.format("http://%s:%s/api/v1/download?file=%%2F";, host, logViewerPort); viewUrl = new URL(String.format("%s/%s%s%d%sworker.log", viewUrlStr, topoId, sep, executorPort, sep)); downloadUrl = new URL(String.format("%s/%s%s%d%sworker.log", downloadUrlStr, topoId, sep, executorPort, sep)); this.componentId = componentId;
