Skip to content

Commit b5d13a4

Browse files
committed
nit
1 parent 3a77784 commit b5d13a4

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

website/docs/quickstart/flink.md

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ mkdir fluss-quickstart-flink
3333
cd fluss-quickstart-flink
3434
```
3535

36-
2. Create a Dockerfile named fluss.Dockerfile as follows. You can change the Flink to your desired version. Please make sure to download the compatible [fluss-flink connector jar](/downloads), [flink-connector-faker](https://github.com/knaufk/flink-faker/releases) in the following Dockerfile.
36+
2. Create a Dockerfile named `fluss.Dockerfile` as follows. You can adjust the Flink version as needed. Please make sure to download the compatible versions of [fluss-flink connector jar](/downloads), [flink-connector-faker](https://github.com/knaufk/flink-faker/releases) in the Dockerfile.
3737

3838
```yaml
3939
FROM flink:1.20.2-scala_2.12
@@ -115,7 +115,7 @@ services:
115115

116116
The Docker Compose environment consists of the following containers:
117117
- **Fluss Cluster:** a Fluss `CoordinatorServer`, a Fluss `TabletServer` and a `ZooKeeper` server.
118-
- **Flink Cluster**: a Flink `JobManager` and a Flink `TaskManager` container to execute queries.
118+
- **Flink Cluster**: a Flink `JobManager`, a Flink `TaskManager`, and a Flink SQL client container to execute queries.
119119

120120
3. To start all containers, run:
121121
```shell
@@ -165,7 +165,9 @@ CREATE TEMPORARY TABLE source_order (
165165
'fields.order_priority.expression' = '#{regexify ''(low|medium|high){1}''}',
166166
'fields.clerk.expression' = '#{regexify ''(Clerk1|Clerk2|Clerk3|Clerk4){1}''}'
167167
);
168+
```
168169

170+
```sql title="Flink SQL"
169171
CREATE TEMPORARY TABLE source_customer (
170172
`cust_key` INT,
171173
`name` STRING,
@@ -184,7 +186,9 @@ CREATE TEMPORARY TABLE source_customer (
184186
'fields.acctbal.expression' = '#{number.randomDouble ''3'',''1'',''1000''}',
185187
'fields.mktsegment.expression' = '#{regexify ''(AUTOMOBILE|BUILDING|FURNITURE|MACHINERY|HOUSEHOLD){1}''}'
186188
);
189+
```
187190

191+
```sql title="Flink SQL"
188192
CREATE TEMPORARY TABLE `source_nation` (
189193
`nation_key` INT NOT NULL,
190194
`name` STRING,

0 commit comments

Comments
 (0)