This is an automated email from the ASF dual-hosted git repository.
agresch pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new 6807f1d41 MINOR: add blobstore documentation for workerRestart (#3485)
6807f1d41 is described below
commit 6807f1d41f6562810251384ff562713eabb49f92
Author: Aaron Gresch <[email protected]>
AuthorDate: Tue Jul 5 14:33:09 2022 -0500
MINOR: add blobstore documentation for workerRestart (#3485)
---
docs/distcache-blobstore.md | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/docs/distcache-blobstore.md b/docs/distcache-blobstore.md
index dfce55200..a5897c4cd 100644
--- a/docs/distcache-blobstore.md
+++ b/docs/distcache-blobstore.md
@@ -65,10 +65,11 @@ The access given to all users being read, write and admin
with a replication fac
Users can submit their topology with the following command. The command
includes the
topology map configuration. The configuration holds two keys “key1” and “key2”
with the
key “key1” having a local file name mapping named “blob_file” and it is not
compressed.
+Workers will restart when the key1 file is updated on the supervisors.
```
storm jar
/home/y/lib/storm-starter/current/storm-starter-jar-with-dependencies.jar
-org.apache.storm.starter.clj.word_count test_topo -c
topology.blobstore.map='{"key1":{"localname":"blob_file",
"uncompress":false},"key2":{}}'
+org.apache.storm.starter.clj.word_count test_topo -c
topology.blobstore.map='{"key1":{"localname":"blob_file", "uncompress":false,
"workerRestart":true},"key2":{}}'
```
### Blob Creation Process
@@ -432,7 +433,7 @@ both the optional parameters are omitted, this file will
get the local name =
It is possible for the cached files to be updated while topologies are running.
The update happens in an eventual consistency model, where the supervisors poll
-Nimbus every 30 seconds, and update their local copies. In the current version,
+Nimbus every supervisor.localizer.update.blob.interval.secs seconds, and
update their local copies. In the current version,
it is the user's responsibility to check whether a new file is available.
To update a cached file, use the following command. Contents come from a FILE
or
