Skip to content

Commit

Permalink
Issue-190: Wrong package name in Flink samples doc (#189)
Browse files Browse the repository at this point in the history
Fixed package name in Flink examples docs.

Signed-off-by: Elizabeth Bain <[email protected]>
  • Loading branch information
elizabethbain authored and RaulGracia committed Apr 2, 2019
1 parent fb614b2 commit e0d152c
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions flink-connector-examples/doc/flink-wordcount/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -72,15 +72,15 @@ Point your browser to `http://<your_flink_host>:8081` to make sure Flink is runn
### Start WordCountWriter
```
$ cd flink-examples/build/install/pravega-flink-examples
$ flink run -m localhost:6123 -c io.pravega.examples.flink.wordcount.WordCountWriter lib/pravega-flink-examples-0.2.0-SNAPSHOT-all.jar --host localhost --port 9999 --controller tcp://localhost:9090
$ flink run -m localhost:6123 -c io.pravega.example.flink.wordcount.WordCountWriter lib/pravega-flink-examples-0.2.0-SNAPSHOT-all.jar --host localhost --port 9999 --controller tcp://localhost:9090
```
The `WordCountWriter` job should show up on the Flink UI as a running job.

### Start WordCountReader
In a different window:
```
$ cd flink-examples/build/install/pravega-flink-examples
$ flink run -m localhost:6123 -c io.pravega.examples.flink.wordcount.WordCountReader lib/pravega-flink-examples-0.2.0-SNAPSHOT-all.jar --controller tcp://localhost:9090
$ flink run -m localhost:6123 -c io.pravega.example.flink.wordcount.WordCountReader lib/pravega-flink-examples-0.2.0-SNAPSHOT-all.jar --controller tcp://localhost:9090
```
The `WordCountReader` job should show up on the Flink UI as a running job.

Expand Down Expand Up @@ -109,7 +109,7 @@ Submit `WordCountWriter` job
- Browser to flink-examples/build/install/pravega-flink-examples/lib and select the uber jar file: pravega-flink-examples-0.2.0-SNAPSHOT-**all**.jar
- Click **Upload** button
- Click the checkbox next to the uploaded jar file.
- In the **Entry Class** field, enter: ```io.pravega.examples.flink.wordcount.WordCountWriter```
- In the **Entry Class** field, enter: ```io.pravega.example.flink.wordcount.WordCountWriter```
- In the **Program Arguments** field, enter: ```--host localhost --port 9999 --controller tcp://localhost:9090```
- Click **Submit** button

Expand All @@ -118,7 +118,7 @@ Submit `WordCountWriter` job
Submit `WordCountReader` job

Repeat the steps above except
- in the **Entry Class** field, enter: ```io.pravega.examples.flink.wordcount.WordCountReader```
- in the **Entry Class** field, enter: ```io.pravega.example.flink.wordcount.WordCountReader```
- in the **Program Arguments** field, enter: ```--controller tcp://localhost:9090```

## IDE Setup
Expand Down
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.

0 comments on commit e0d152c

Please sign in to comment.