Commit ca78b56

jiangqiao.xu

committed

[Enhancement] Add an option to config timeout for committing transaction

Signed-off-by: jiangqiao.xu <jiangqiao.xu@nio.com>

1 parent 18f7f1e commit ca78b56Copy full SHA for ca78b56

5 files changed

+51

-27

lines changed

docs/content
- connector-sink.md
src/main/java/com/starrocks/connector/flink/table/sink
- StarRocksDynamicTableSinkFactory.java
- StarRocksSinkOptions.java
starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream
- TransactionStreamLoader.java
- properties
  - StreamLoadProperties.java

+51

-27

lines changed

Comments

(0)