[
https://issues.apache.org/jira/browse/STORM-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987844#comment-14987844
]
ASF GitHub Bot commented on STORM-876:
--------------------------------------
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/845#discussion_r43788727
--- Diff: bin/storm.py ---
@@ -263,6 +263,34 @@ def upload_credentials(*args):
jvmtype="-client",
extrajars=[USER_CONF_DIR, STORM_BIN_DIR])
+def blobstore(*args):
+ """Syntax: [storm blobstore [cmd]]
+
+ list [KEY...] - lists blobs currently in the blob store
+ cat [-f FILE] KEY - read a blob and then either write it to a file, or
STDOUT (requires read access).
+ create [-f FILE] [-a ACL ...] [--repl-fctr NUMBER] KEY - create a new
blob. Contents comes from a FILE
+ or STDIN. ACL is in the form [uo]:[username]:[r-][w-][a-] can be
comma
+ separated list.
+ --repl-fctr refers to replication factor for the blob. Here
NUMBER > 0.
+ for example the following would create a mytopo:data.tgz key
using the data
+ stored in data.tgz. User alice would have full access, bob would
have
+ read/write access and everyone else would have read access.
+ storm blobstore create mytopo:data.tgz -f data.tgz -a
u:alice:rwa,u:bob:rw,o::r
+ update [-f FILE] KEY - update the contents of a blob. Contents comes
from
+ a FILE or STDIN (requires write access).
+ delete KEY - delete an entry from the blob store (requires write
access).
+ set-acl [-s ACL] KEY - ACL is in the form [uo]:[username]:[r-][w-][a-]
can be comma
+ separated list (requires admin access).
+ replication --read KEY - Used to read the replication factor of the
blob.
+ replication --update --repl-fctr NUMBER KEY - NUMBER > 0. It is used
to update the
--- End diff --
Same here, rename to `--replication-factor`?
> Dist Cache: Basic Functionality
> -------------------------------
>
> Key: STORM-876
> URL: https://issues.apache.org/jira/browse/STORM-876
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-core
> Reporter: Robert Joseph Evans
> Assignee: Robert Joseph Evans
> Attachments: DISTCACHE.md, DistributedCacheDesignDocument.pdf
>
>
> Basic functionality for the Dist Cache feature.
> As part of this a new API should be added to support uploading and
> downloading dist cache items. storm-core.ser, storm-conf.ser and storm.jar
> should be written into the blob store instead of residing locally. We need a
> default implementation of the blob store that does essentially what nimbus
> currently does and does not need anything extra. But having an HDFS backend
> too would be great for scalability and HA.
> The supervisor should provide a way to download and manage these blobs and
> provide a working directory for the worker process with symlinks to the
> blobs. It should also allow the blobs to be updated and switch the symlink
> atomically to point to the new blob once it is downloaded.
> All of this is already done by code internal to Yahoo! we are in the process
> of getting it ready to push back to open source shortly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
