StarRocks starrocks-connector-for-apache-flink issues

StarRocks / starrocks-connector-for-apache-flink

Apache License 2.0

195 stars 160 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

[SecurityFix] Updating alibaba fastjson to take care of CVE-2022-25845

#394 gdrossi46 closed 1 week ago
6
添加sink label后，task自动重启不能恢复

#393 lppsuixn opened 1 week ago
0
Add Parameter to Ignore Delete Messages in Flink StarRocks Connector (Default: false)

#392 bugbubug opened 2 weeks ago
1
Bump version to 1.2.11-SNAPSHOT

#391 banmoy closed 4 weeks ago
0
[Doc] Add doc for the incoming 1.2.10

#390 banmoy closed 4 weeks ago
0
[Enhancement] build starrocks-thrift-sdk with docker

#389 kyo-tom opened 1 month ago
1
Build the starrocks-thrift-sdk module using docker

#388 kyo-tom opened 1 month ago
0
[UT] Add tests for reading and write StarRocks DATETIME

#387 banmoy closed 2 months ago
0
Sink support datetime microsecond

#386 wyb closed 2 months ago
2
support flink 1.20

#385 melin opened 2 months ago
0
[Bugfix] Prepare failed when the transaction still in processing

#384 gohalo opened 2 months ago
0
[Bug] Write to StarRocks failed occasionally.

#383 gohalo opened 2 months ago
0
[bugfix] Fix the bug that flink decimal cannot be converted to the starRocks bigint unsigned data type.

#382 danzhewuju opened 3 months ago
1
[Bug] Flink Decimal(20, 0) cannot be converted to the StarRocks bigint unsigned data type.

#381 danzhewuju opened 3 months ago
0
[BugFix] Fix exception when loading empty json string to json column

#380 banmoy closed 2 months ago
0
[Feature] Support Flink 1.19

#379 banmoy closed 3 months ago
0
starrocks 用官网给出的 csv 例子 sink 端一直在 INITIALIZING

#378 yuxuan-luo opened 3 months ago
0
[BUG] StarRocksSink 重试多次后死锁

#377 songpinru opened 4 months ago
0
[BugFix] Fix predicate push-down time dimension table error

#376 hhoao opened 4 months ago
1
[BugFix] predicate push-down time dimension table error

#375 hhoao opened 4 months ago
0
[BugFix] Causing index out of bounds (#373)

#374 kinoxyz1 opened 4 months ago
2
[BugFix] Causing index out of bounds

#373 kinoxyz1 opened 4 months ago
0
[BugFix] Index out of range exception occurs in certain data types

#372 kinoxyz1 opened 4 months ago
0
[BugFix] Index out of range exception occurs in certain data types

#371 kinoxyz1 opened 4 months ago
0
[#369][Bugfix] Change the starrocks connector UNKNOWN data type handle method

#370 XiaoYou201 opened 4 months ago
2
[Bug] The starrocks connector unknown datatype handle method maybe need to change

#369 XiaoYou201 opened 4 months ago
0
[#367][BugFix]enhance unqualified load-url config validate and test

#368 xumanbu opened 5 months ago
2
[BUG] Error occurred in DefaultStreamLoader#getAvailableHost while trying to load a URL due to configuration issues.

#367 xumanbu opened 5 months ago
0
[BugFix] Fix incorrect result for date formatting

#366 dusukang opened 5 months ago
2
[BugFix] Resolve Delete Semantics Data Loss in Flink SQL for StarRocks 3.1

#365 andystenhe opened 6 months ago
1
In the 3.1 separated storage and computation version, the use of the "insert into" statement in Flink SQL will lose the data with delete rowkind.

#364 andystenhe opened 6 months ago
0
The AsyncTableFunction can be used for Flink lookup join StarRocks dimension table

#363 chestnutqiang opened 6 months ago
0
不支持二进制数据（binary、bytes）的读取和写入

#362 liuka11 opened 6 months ago
1
[Enhancement] Support to set warehouse when using transaction stream load

#361 banmoy closed 6 months ago
0
修复文档中sink.label-prefix 的默认值说明

#360 aubdiy opened 6 months ago
1
Will StarRocks source support custom SQL queries in the future

#359 franran opened 7 months ago
0
[BugFix] Fix a typo in class StarRocksTableRowTransformer

#358 jiandongchen opened 7 months ago
0
enhancement: support alter modify columns' type and position

#357 yuxiqian opened 7 months ago
1
[BugFix] Fail to add custom stream load table properties

#356 Lyang77 closed 6 months ago
4
[BugFix] Fix a typo in class StarRocksDynamicSinkFunction

#355 jiandongchen opened 7 months ago
1
[Feature] Sink supports LZ4 compression with json format

#354 banmoy closed 7 months ago
0
容器部署starrocks, Flink Sink连接发生 xx.xx.xx.xx:8040 Connection timed out

#353 wayne-wei-q opened 7 months ago
0
[Enhancement] Support to map a subset of StarRocks columns to Flink source table

#352 banmoy closed 7 months ago
0
[BugFix] Close StarRocksSourceBeReader in StarRocksDynamicLookupFunction

#351 banmoy closed 7 months ago
0
[BugFix] Remove column name check for arrow

#350 banmoy closed 7 months ago
0
[Doc] Fix wrong flink cdc link

#349 banmoy closed 7 months ago
0
Update StarRocksSinkOptions.java

#348 uicosp opened 8 months ago
1
[Feature] Support to read ARRAY/STRUCT/MAP

#347 banmoy closed 8 months ago
0
[Feature] flink source无法读取json字段

#346 wmtbnbo closed 7 months ago
1
support load data from starrocks table by specific condition

#345 billowsoft opened 8 months ago
1