Issues
- 2
Sink support datetime microsecond
#386 opened by wyb - 0
support flink 1.20
#385 opened by melin - 0
[Bug] Write to StarRocks failed occasionally.
#383 opened by gohalo - 0
[Bug] Flink Decimal(20, 0) cannot be converted to the StarRocks bigint unsigned data type.
#381 opened by danzhewuju - 0
[BugFix] Causing index out of bounds
#373 opened by kinoxyz1 - 0
starrocks 用官网给出的 csv 例子 sink 端一直在 INITIALIZING
#378 opened by yuxuan-luo - 0
[BUG] StarRocksSink 重试多次后死锁
#377 opened by songpinru - 0
[BugFix] predicate push-down time dimension table error
#375 opened by hhoao - 0
- 0
[Bug] The starrocks connector unknown datatype handle method maybe need to change
#369 opened by XiaoYou201 - 0
[BUG] Error occurred in DefaultStreamLoader#getAvailableHost while trying to load a URL due to configuration issues.
#367 opened by xumanbu - 0
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 opened by andystenhe - 0
The AsyncTableFunction can be used for Flink lookup join StarRocks dimension table
#363 opened by chestnutqiang - 1
不支持二进制数据(binary、bytes)的读取和写入
#362 opened by liuka11 - 0
- 0
- 1
[Feature] flink source无法读取json字段
#346 opened by wmtbnbo - 1
- 0
sync add/drop schema change by debezium
#337 opened by chenhaifengkeda - 0
flink cdc 同步写入starrocks,支持schema变更
#288 opened by melin - 0
support MySQL's entire database synchronization without many Flink SQL
#332 opened by chenhaifengkeda - 0
- 0
- 2
[Docs]: BINARY类型映射不对
#327 opened by hubble-insight - 0
mysql to SR , 如何支持同时导入多表?
#322 opened by renzhimin7 - 0
支持自定义StarRocksGenericRowTransformer 清洗数据
#323 opened by renzhimin7 - 2
- 4
StarRocks 3.1.4版本访问hive库中用了udf 的视图报错
#306 opened by phoenixhadoop - 2
flink-connector-starrocks 读取json字段异常,空指针?
#304 opened by TonyHowardPark - 1
Snapshot state failed by prepare
#225 opened by fly-shark - 4
- 2
StarRocksSinkManagerV2 unsupport redirect becuase StreamLoadEntity is not repeatable
#302 opened by MyLanPangzi - 3
- 4
[Enhancement] look function support partial cache
#293 opened by Jin-H - 0
Thread name can easily mislead users when use spark
#290 opened by Jin-H - 0
org.apache.flink.table.api.TableSchema已弃用,是否考虑StarRocksDynamicSourceFunction中进行修改?
#289 opened by aesirteam - 4
Support stream load into BE
#244 opened by rohankrao - 2
- 2
如何写入bitmap字段
#217 opened by ltylty - 3
啥时候能支持flink1.17呀?
#224 opened by fi-ecavc - 1
有计划支持catalog的api吗
#255 opened by zouchangzhen - 3
multi-segment only supported by pure upsert/delete, so pure upsert after another operation is illegal?
#257 opened by zouchangzhen - 1
Sink SR 异常回调
#287 opened by lx-jialin - 5
Flink MySQL CDC writes to a Starrocks primary key model table, facing data synchronization latency issue
#273 opened by nathan-szz - 0
- 0
FlinkSql sink.properties.columns 中使用 bitmap_from_string 函数,好像使用不了?我这个用法正确么
#261 opened by zouchangzhen - 1
mvn error. You have to use a classifier to attach supplemental artifacts to the project instead of replacing them.
#237 opened by alberttwong - 0
Support exactly-once reading in the connector
#236 opened by rohankrao - 2
多表sink目前有除了smt的解决方案吗?
#226 opened by TurnoffyourTV - 0