starrocks-connector-for-apache-flink

starrocks-connector-for-apache-flink copied to clipboard

If you use asynchronous queries, the AsyncTableFunction can increase the throughput of the StarRocks dimension table

chestnutqiang

不支持二进制数据（binary、bytes）的读取和写入

1

java.lang.UnsupportedOperationException: Unsupported type:BYTES at com.starrocks.connector.flink.row.sink.StarRocksTableRowTransformer.typeConvertion(StarRocksTableRowTransformer.java:183) at com.starrocks.connector.flink.row.sink.StarRocksTableRowTransformer.transform(StarRocksTableRowTransformer.java:96) at com.starrocks.connector.flink.row.sink.StarRocksTableRowTransformer.transform(StarRocksTableRowTransformer.java:50) at com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2.invoke(StarRocksDynamicSinkFunctionV2.java:164)

liuka11

support flink 1.20

melin

## What type of PR is this： - [x] BugFix - [ ] Feature - [ ] Enhancement - [ ] Refactor - [ ] UT - [ ] Doc...

gohalo

Got the following error message from flink task manager. ``` 2024-09-05 06:33:49,271 | ERROR | [StarRocks-Sink-Manager] | Transaction prepare failed, db: ods, table: ods_fin_cust_account_t_keep_acct_detail_ri, label: flink-49e51069-70b2-41ee-8c22-d40d07a6e3d3, [N]responseBody: {[N] "Status": "TXN_IN_PROCESSING",[N]...

gohalo

[bugfix] Fix the bug that flink decimal cannot be converted to the starRocks bigint unsigned data type.

1

## What type of PR is this： - [x] BugFix - [ ] Feature - [ ] Enhancement - [ ] Refactor - [ ] UT - [ ] Doc...

danzhewuju

# Environment My StarRocks table has a column of type 'BIGINT UNSIGNED'. I created a StarRocks sink table with the following structure: `CREATE TABLE starrocks_sink (`userId` decimal(20,0))` # Error information...

danzhewuju