StarRocks/starrocks-connector-for-apache-flink issues and pull requests

#410 - Any plan to support Arrow Flight in stream load library

Issue - State: open - Opened by grant-guo 16 days ago

#409 - Add support for flink 1.20

Pull Request - State: closed - Opened by Hatlassian about 1 month ago - 1 comment

#406 - Support dynamic writing to multiple tables

Issue - State: closed - Opened by fcb-xiaobo 2 months ago

#405 - Add ignore delete parameter

Pull Request - State: open - Opened by bugbubug 2 months ago

#404 - Add sink-side parameter to ignore deletion.

Pull Request - State: closed - Opened by bugbubug 2 months ago - 1 comment

#403 - Add ignore delete parameter

Pull Request - State: closed - Opened by bugbubug 2 months ago - 1 comment

#402 - [BugFix] fix log error on StarRocksCatalog when invoke createTable

Pull Request - State: open - Opened by ZhicongZheng 3 months ago - 1 comment

#401 - In the 3.3.7 separated storage and computation version, Flink connector accidentally split Flink into multiple jobs by writing SR

Issue - State: open - Opened by lukeyan2023 3 months ago

#400 - [Feature] Support truncate event for flinkcdc

Pull Request - State: open - Opened by jhnwh 3 months ago

#399 - [Enhancement] Support truncate event for flinkcdc

Pull Request - State: closed - Opened by jhnwh 3 months ago - 1 comment

#398 - [Enhancement] Support truncate event for flinkcdc

Pull Request - State: closed - Opened by jhnwh 3 months ago - 1 comment

#397 - Add support for truncate events in Connector

Issue - State: open - Opened by jhnwh 3 months ago

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

Pull Request - State: open - Opened by bridgeDream 3 months ago - 1 comment

#395 - Flink throw StreamLoadFailException when get database write lock timeout

Issue - State: open - Opened by bridgeDream 3 months ago

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

Pull Request - State: closed - Opened by gdrossi46 3 months ago - 6 comments

#393 - 添加sink label后，task自动重启不能恢复

Issue - State: open - Opened by lppsuixn 3 months ago

#393 - 添加sink label后，task自动重启不能恢复

Issue - State: open - Opened by lppsuixn 3 months ago

#392 - Add Parameter to Ignore Delete Messages in Flink StarRocks Connector (Default: false)

Issue - State: open - Opened by bugbubug 4 months ago - 1 comment

#391 - Bump version to 1.2.11-SNAPSHOT

Pull Request - State: closed - Opened by banmoy 4 months ago

#391 - Bump version to 1.2.11-SNAPSHOT

Pull Request - State: closed - Opened by banmoy 4 months ago

#390 - [Doc] Add doc for the incoming 1.2.10

Pull Request - State: closed - Opened by banmoy 4 months ago

#390 - [Doc] Add doc for the incoming 1.2.10

Pull Request - State: closed - Opened by banmoy 4 months ago

#389 - [Enhancement] build starrocks-thrift-sdk with docker

Pull Request - State: open - Opened by kyo-tom 4 months ago - 1 comment

#388 - Build the starrocks-thrift-sdk module using docker

Issue - State: open - Opened by kyo-tom 4 months ago

#388 - Build the starrocks-thrift-sdk module using docker

Issue - State: open - Opened by kyo-tom 4 months ago

#387 - [UT] Add tests for reading and write StarRocks DATETIME

Pull Request - State: closed - Opened by banmoy 5 months ago

#386 - Sink support datetime microsecond

Issue - State: closed - Opened by wyb 5 months ago - 2 comments

#386 - Sink support datetime microsecond

Issue - State: closed - Opened by wyb 5 months ago - 2 comments

#385 - support flink 1.20

Issue - State: closed - Opened by melin 5 months ago - 1 comment

#385 - support flink 1.20

Issue - State: closed - Opened by melin 5 months ago - 1 comment

#384 - [Bugfix] Prepare failed when the transaction still in processing

Pull Request - State: open - Opened by gohalo 5 months ago

#383 - [Bug] Write to StarRocks failed occasionally.

Issue - State: open - Opened by gohalo 5 months ago

#383 - [Bug] Write to StarRocks failed occasionally.

Issue - State: open - Opened by gohalo 5 months ago

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

Pull Request - State: open - Opened by danzhewuju 6 months ago - 1 comment

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

Pull Request - State: open - Opened by danzhewuju 6 months ago - 1 comment

#381 - [Bug] Flink Decimal(20, 0) cannot be converted to the StarRocks bigint unsigned data type.

Issue - State: open - Opened by danzhewuju 6 months ago

#381 - [Bug] Flink Decimal(20, 0) cannot be converted to the StarRocks bigint unsigned data type.

Issue - State: open - Opened by danzhewuju 6 months ago

#380 - [BugFix] Fix exception when loading empty json string to json column

Pull Request - State: closed - Opened by banmoy 6 months ago

#380 - [BugFix] Fix exception when loading empty json string to json column

Pull Request - State: closed - Opened by banmoy 6 months ago

#379 - [Feature] Support Flink 1.19

Pull Request - State: closed - Opened by banmoy 7 months ago

#379 - [Feature] Support Flink 1.19

Pull Request - State: closed - Opened by banmoy 7 months ago

#378 - starrocks 用官网给出的 csv 例子 sink 端一直在 INITIALIZING

Issue - State: open - Opened by yuxuan-luo 7 months ago

#378 - starrocks 用官网给出的 csv 例子 sink 端一直在 INITIALIZING

Issue - State: open - Opened by yuxuan-luo 7 months ago

#377 - [BUG] StarRocksSink 重试多次后死锁

Issue - State: open - Opened by songpinru 7 months ago

#376 - [BugFix] Fix predicate push-down time dimension table error

Pull Request - State: open - Opened by hhoao 7 months ago - 1 comment

#375 - [BugFix] predicate push-down time dimension table error

Issue - State: open - Opened by hhoao 7 months ago

#375 - [BugFix] predicate push-down time dimension table error

Issue - State: open - Opened by hhoao 7 months ago

#374 - [BugFix] Causing index out of bounds (#373)

Pull Request - State: closed - Opened by kinoxyz1 7 months ago - 2 comments

#373 - [BugFix] Causing index out of bounds

Issue - State: open - Opened by kinoxyz1 7 months ago

#373 - [BugFix] Causing index out of bounds

Issue - State: open - Opened by kinoxyz1 7 months ago

#372 - [BugFix] Index out of range exception occurs in certain data types

Pull Request - State: closed - Opened by kinoxyz1 7 months ago

#372 - [BugFix] Index out of range exception occurs in certain data types

Pull Request - State: open - Opened by kinoxyz1 7 months ago

#371 - [BugFix] Index out of range exception occurs in certain data types

Issue - State: open - Opened by kinoxyz1 7 months ago

#371 - [BugFix] Index out of range exception occurs in certain data types

Issue - State: open - Opened by kinoxyz1 7 months ago

#370 - [#369][Bugfix] Change the starrocks connector UNKNOWN data type handle method

Pull Request - State: open - Opened by XiaoYou201 8 months ago - 2 comments

#370 - [#369][Bugfix] Change the starrocks connector UNKNOWN data type handle method

Pull Request - State: open - Opened by XiaoYou201 8 months ago - 2 comments

#369 - [Bug] The starrocks connector unknown datatype handle method maybe need to change

Issue - State: open - Opened by XiaoYou201 8 months ago

#369 - [Bug] The starrocks connector unknown datatype handle method maybe need to change

Issue - State: open - Opened by XiaoYou201 8 months ago

#368 - [#367][BugFix]enhance unqualified load-url config validate and test

Pull Request - State: open - Opened by xumanbu 8 months ago - 2 comments

#368 - [#367][BugFix]enhance unqualified load-url config validate and test

Pull Request - State: open - Opened by xumanbu 8 months ago - 2 comments

#367 - [BUG] Error occurred in DefaultStreamLoader#getAvailableHost while trying to load a URL due to configuration issues.

Issue - State: open - Opened by xumanbu 8 months ago

#367 - [BUG] Error occurred in DefaultStreamLoader#getAvailableHost while trying to load a URL due to configuration issues.

Issue - State: open - Opened by xumanbu 8 months ago

#366 - [BugFix] Fix incorrect result for date formatting

Pull Request - State: open - Opened by dusukang 8 months ago - 2 comments

#366 - [BugFix] Fix incorrect result for date formatting

Pull Request - State: open - Opened by dusukang 8 months ago - 2 comments

#365 - [BugFix] Resolve Delete Semantics Data Loss in Flink SQL for StarRocks 3.1

Pull Request - State: open - Opened by andystenhe 9 months ago - 1 comment

#365 - [BugFix] Resolve Delete Semantics Data Loss in Flink SQL for StarRocks 3.1

Pull Request - State: open - Opened by andystenhe 9 months ago - 1 comment

#364 - 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.

Issue - State: open - Opened by andystenhe 9 months ago

#364 - 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.

Issue - State: open - Opened by andystenhe 9 months ago

#363 - The AsyncTableFunction can be used for Flink lookup join StarRocks dimension table

Issue - State: open - Opened by chestnutqiang 9 months ago

#363 - The AsyncTableFunction can be used for Flink lookup join StarRocks dimension table

Issue - State: open - Opened by chestnutqiang 9 months ago

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

Issue - State: open - Opened by liuka11 10 months ago - 1 comment

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

Issue - State: open - Opened by liuka11 10 months ago - 1 comment

#361 - [Enhancement] Support to set warehouse when using transaction stream load

Pull Request - State: closed - Opened by banmoy 10 months ago

#360 - 修复文档中sink.label-prefix 的默认值说明

Pull Request - State: open - Opened by aubdiy 10 months ago - 1 comment

#360 - 修复文档中sink.label-prefix 的默认值说明

Pull Request - State: open - Opened by aubdiy 10 months ago - 1 comment

#359 - Will StarRocks source support custom SQL queries in the future

Issue - State: open - Opened by franran 10 months ago

#359 - Will StarRocks source support custom SQL queries in the future

Issue - State: open - Opened by franran 10 months ago

#358 - [BugFix] Fix a typo in class StarRocksTableRowTransformer

Pull Request - State: open - Opened by jiandongchen 10 months ago

#358 - [BugFix] Fix a typo in class StarRocksTableRowTransformer

Pull Request - State: open - Opened by jiandongchen 10 months ago

#357 - enhancement: support alter modify columns' type and position

Pull Request - State: open - Opened by yuxiqian 10 months ago - 1 comment

#357 - enhancement: support alter modify columns' type and position

Pull Request - State: open - Opened by yuxiqian 10 months ago - 1 comment

#356 - [BugFix] Fail to add custom stream load table properties

Pull Request - State: closed - Opened by Lyang77 10 months ago - 4 comments

#356 - [BugFix] Fail to add custom stream load table properties

Pull Request - State: closed - Opened by Lyang77 10 months ago - 4 comments

#355 - [BugFix] Fix a typo in class StarRocksDynamicSinkFunction

Pull Request - State: open - Opened by jiandongchen 10 months ago - 1 comment

#355 - [BugFix] Fix a typo in class StarRocksDynamicSinkFunction

Pull Request - State: open - Opened by jiandongchen 10 months ago - 1 comment

#354 - [Feature] Sink supports LZ4 compression with json format

Pull Request - State: closed - Opened by banmoy 10 months ago

#354 - [Feature] Sink supports LZ4 compression with json format

Pull Request - State: closed - Opened by banmoy 10 months ago

#353 - 容器部署starrocks, Flink Sink连接发生 xx.xx.xx.xx:8040 Connection timed out

Issue - State: open - Opened by wayne-wei-q 10 months ago