Skip to content

Commit

Permalink
release 1.1.13
Browse files Browse the repository at this point in the history
  • Loading branch information
hffariel committed Dec 6, 2021
1 parent f3ce300 commit 1aaf680
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

## Prerequisites

### Intgerate with your existing project
### Intgerate into your existing project

```xml
<dependency>
Expand All @@ -17,7 +17,7 @@
</dependency>
```

Click [here](https://search.maven.org/search?q=g:com.starrocks) to get the latest version.
Click [HERE](https://search.maven.org/search?q=g:com.starrocks) to get the latest version.

### Start using like

Expand Down Expand Up @@ -92,7 +92,6 @@ fromElements(
```java

// create a table with `structure` and `properties`
// Needed: Add `com.starrocks.connector.flink.table.StarRocksDynamicTableSinkFactory` to: `src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory`
tEnv.executeSql(
"CREATE TABLE USER_RESULT(" +
"name VARCHAR," +
Expand Down Expand Up @@ -148,4 +147,5 @@ tEnv.executeSql(

### Notes

`Flush` was triggered(`at-least-once`) when: `cachedRows >= ${sink.buffer-flush.max-rows} || cachedBytes >= ${sink.buffer-flush.max-bytes} || idleTime >= ${sink.buffer-flush.interval-ms}`
1. `Flush` action was triggered `at-least-once` when: `cachedRows >= ${sink.buffer-flush.max-rows} || cachedBytes >= ${sink.buffer-flush.max-bytes} || idleTime >= ${sink.buffer-flush.interval-ms}`
2. `sink.buffer-flush.{max-rows|max-bytes|interval-ms}` becomes invalid when it comes with the `exactly-once` semantic.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ limitations under the License.
<modelVersion>4.0.0</modelVersion>
<groupId>com.starrocks</groupId>
<artifactId>flink-connector-starrocks</artifactId>
<version>1.1.12_flink-1.13</version>
<version>1.1.13_flink-1.13</version>
<properties>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
Expand Down

0 comments on commit 1aaf680

Please sign in to comment.