Skip to content

Commit

Permalink
[#6243] fix(docs): Fix wrong seperator of yaml example in flink-conne…
Browse files Browse the repository at this point in the history
…ctor.md (#6259)

### What changes were proposed in this pull request?

Replace `=` with `:` to correct the yaml example.

### Why are the changes needed?
The yaml example uses wrong seperator.

Fix: #6243

### Does this PR introduce _any_ user-facing change?
None

### How was this patch tested?
None.
  • Loading branch information
frankvicky authored and web-flow committed Jan 15, 2025
1 parent 08d3e1e commit a113b5c
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions docs/flink-connector/flink-connector.md
Original file line number Diff line number Diff line change
Expand Up @@ -34,16 +34,16 @@ This capability allows users to perform federation queries, accessing data from

Set the flink configuration in flink-conf.yaml.
```yaml
table.catalog-store.kind=gravitino
table.catalog-store.gravitino.gravitino.metalake=test
table.catalog-store.gravitino.gravitino.uri=http://localhost:8080
table.catalog-store.kind: gravitino
table.catalog-store.gravitino.gravitino.metalake: test
table.catalog-store.gravitino.gravitino.uri: http://localhost:8090
```
Or you can set the flink configuration in the `TableEnvironment`.
```java
final Configuration configuration = new Configuration();
configuration.setString("table.catalog-store.kind", "gravitino");
configuration.setString("table.catalog-store.gravitino.gravitino.metalake", "test");
configuration.setString("table.catalog-store.gravitino.gravitino.uri", "http://localhost:8080");
configuration.setString("table.catalog-store.gravitino.gravitino.uri", "http://localhost:8090");
EnvironmentSettings.Builder builder = EnvironmentSettings.newInstance().withConfiguration(configuration);
TableEnvironment tableEnv = TableEnvironment.create(builder.inBatchMode().build());
```
Expand Down

0 comments on commit a113b5c

Please sign in to comment.