Skip to content

Commit

Permalink
format the example code in the docs/README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
cfmcgrady committed Jul 26, 2023
1 parent e708c3c commit 37a1c50
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions docs/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -97,9 +97,11 @@ cd $SPARK_HOME
```
Then run the following test case:
```scala
spark.sparkContext.parallelize(1 to 10, 10)
.flatMap( _ => (1 to 100).iterator
.map(num => num)).repartition(10).count
spark.sparkContext
.parallelize(1 to 10, 10)
.flatMap(_ => (1 to 100).iterator.map(num => num))
.repartition(10)
.count
```
During the Spark Job, you should see the following message in Celeborn Master's log:
```shell
Expand All @@ -110,4 +112,4 @@ And the following message in Celeborn Worker's log:
23/07/22 12:29:57,952 INFO [dispatcher-event-loop-9] Controller: Reserved 10 primary location and 0 replica location for local-1690000152711-0
23/07/22 12:29:58,117 INFO [dispatcher-event-loop-10] Controller: Start commitFiles for local-1690000152711-0
23/07/22 12:29:58,153 INFO [async-reply] Controller: CommitFiles for local-1690000152711-0 success with 10 committed primary partitions, 0 empty primary partitions, 0 failed primary partitions, 0 committed replica partitions, 0 empty replica partitions, 0 failed replica partitions.
```
```

0 comments on commit 37a1c50

Please sign in to comment.