Skip to content

Commit a387649

Browse files
committed
Fixing bug in WS deployment
1 parent 79c9529 commit a387649

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

docs/pubsub/storm-drpc.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ You can communicate with DRPC using [Apache Thrift](https://thrift.apache.org) o
1414
```bash
1515
curl -s -X POST -d '{"id":"", "content":"{}"}' http://<DRPC_SERVER>:<DRPC_PORT>/drpc/<DRPC_FUNCTION_FROM_YOUR_BULLET_CONF>
1616
```
17-
to get a random record from your data instantly (if you left the Raw aggregation micro-batch size at the default of 1). The ```content``` above in the JSON is the actual (empty) Bullet query. This is a quick way to check if your topology is up and running!
17+
to get a random record (inside a JSON representation of a PubSubMessage) from your data instantly if you left the Raw aggregation micro-batch size at the default of 1. The ```content``` above in the JSON is the actual (empty) Bullet query. This is a quick way to check if your topology is up and running!
1818

1919
## Setup
2020

docs/quick-start.md

+3-3
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ Test the Bullet topology by:
158158
curl -s -X POST -d '{"id":"", "content":"{}"}' http://localhost:3774/drpc/bullet-query
159159
```
160160

161-
You should get a random record from Bullet.
161+
You should get a random record (serialized as a String inside a JSON message sent back through the PubSub) from Bullet.
162162

163163
!!! note "What is this data?"
164164

@@ -179,9 +179,9 @@ cp $BULLET_EXAMPLES/storm/*jar-with-dependencies.jar $BULLET_HOME/service/bullet
179179

180180
```bash
181181
cd $BULLET_HOME/service
182-
java -Dloader.path=bullet-storm-jar-with-dependencies.jar -jar bullet-service.jar --bullet.pubsub.config=example_drpc_pubsub_config.yaml --bullet.schema.file=example_columns.json --server.port=9999 --logging.path=. --logging.file=log.txt > log.txt 2>&1 &
182+
java -Dloader.path=bullet-storm-jar-with-dependencies.jar -jar bullet-service.jar --bullet.pubsub.config=example_drpc_pubsub_config.yaml --bullet.schema.file=example_columns.json --server.port=9999 --logging.path=. --logging.file=log.txt &> log.txt &
183183
```
184-
You can verify that it is up by running the Bullet query and getting the example columns through the API:
184+
You can verify that it is up by running a Bullet query or getting the example columns through the API:
185185

186186
```bash
187187
curl -s -H 'Content-Type: text/plain' -X POST -d '{}' http://localhost:9999/api/bullet/query

examples/install-all.sh

+2-2
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ launch_bullet_storm() {
132132
}
133133

134134
launch_bullet_web_service() {
135-
local BULLET_WS_JAR="bullet-service-${BULLET_WS_VERSION}.jar"
135+
local BULLET_WS_JAR="bullet-service-${BULLET_WS_VERSION}-embedded.jar"
136136
local BULLET_SERVICE_HOME="${BULLET_HOME}/service"
137137

138138
println "Downloading Bullet Web Service ${BULLET_WS_VERSION}..."
@@ -147,7 +147,7 @@ launch_bullet_web_service() {
147147
cd "${BULLET_SERVICE_HOME}"
148148
java -Dloader.path=bullet-storm-jar-with-dependencies.jar -jar bullet-service.jar \
149149
--bullet.pubsub.config=example_drpc_pubsub_config.yaml --bullet.schema.file=example_columns.json \
150-
--server.port=9999 --logging.path="${BULLET_SERVICE_HOME}" --logging.file=log.txt > log.txt 2>&1 &
150+
--server.port=9999 --logging.path="${BULLET_SERVICE_HOME}" --logging.file=log.txt &> "${BULLET_SERVICE_HOME}/log.txt" &
151151

152152
println "Sleeping for 15 s to ensure Bullet Web Service is up..."
153153
sleep 15

0 commit comments

Comments
 (0)