storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/2] storm git commit: Merge branch 'STORM-2038-local-mode' of https://github.com/revans2/incubator-storm into STORM-2038
Date Thu, 16 Mar 2017 17:02:28 GMT
Repository: storm
Updated Branches:
  refs/heads/1.0.x-branch 190a1dff2 -> 39b39e8d7


Merge branch 'STORM-2038-local-mode' of https://github.com/revans2/incubator-storm into STORM-2038

STORM-2038: No symlinks for local cluster


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4bc79965
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4bc79965
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4bc79965

Branch: refs/heads/1.0.x-branch
Commit: 4bc79965f3a42375e1d22b4757527544f315d048
Parents: 190a1df
Author: Robert Evans <evans@yahoo-inc.com>
Authored: Thu Mar 16 10:43:03 2017 -0500
Committer: Robert Evans <evans@yahoo-inc.com>
Committed: Thu Mar 16 11:23:37 2017 -0500

----------------------------------------------------------------------
 .../apache/storm/daemon/supervisor/LocalContainer.java  | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/4bc79965/storm-core/src/jvm/org/apache/storm/daemon/supervisor/LocalContainer.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/daemon/supervisor/LocalContainer.java b/storm-core/src/jvm/org/apache/storm/daemon/supervisor/LocalContainer.java
index f21efa4..4ec8028 100644
--- a/storm-core/src/jvm/org/apache/storm/daemon/supervisor/LocalContainer.java
+++ b/storm-core/src/jvm/org/apache/storm/daemon/supervisor/LocalContainer.java
@@ -42,7 +42,17 @@ public class LocalContainer extends Container {
         _sharedContext = sharedContext;
         _workerId = Utils.uuid();
     }
-    
+
+    @Override
+    protected void createArtifactsLink() {
+        //NOOP no need to create links in local mode
+    }
+
+    @Override
+    protected void createBlobstoreLinks() {
+        // NOOP no need to create links in local mode
+    }
+
     @Override
     public void launch() throws IOException {
         //TODO when worker goes to java, just call it directly (not through clojure)


Mime
View raw message