starrocks-connector-for-apache-flink

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

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

1

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

aubdiy

Hello, I have a question to ask. Will starRocks source support custom SQL queries such as join operations?

franran

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

jiandongchen

[BugFix] Fix a typo in class StarRocksDynamicSinkFunction

1

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

jiandongchen

enhancement: support alter modify columns' type and position

1

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

yuxiqian

When I deploy Starrocks in Docker and use Flink-connector-Starrocks to import data, the BE node IP is the internal IP of the container. Flink cannot access this IP. Is there...

wayne-wei-q

debug:Delete the useless parseSinkStreamLoadProperties method

1

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

buvb

support load data from starrocks table by specific condition

1

https://github.com/StarRocks/starrocks-connector-for-apache-flink/blob/08de67ad0f5c3cd9fbc3707466df6c642dfee7e7/src/main/java/com/starrocks/connector/flink/table/source/StarRocksDynamicLookupFunction.java#L99 Current implementation is loading all the data of the table which will cause OOM while the the data volume is too big, suggest can support load data by specific...

billowsoft

Update StarRocksSinkOptions.java

1

auto add `__op` for primary key table even when user specified `sink.properties.columns` ## What type of PR is this： - [x] BugFix - [ ] Feature - [x] Enhancement -...

uicosp

When inserting data like the below: ```java String[] records = new String[]{ "[{\"id\":400, \"name\":\"400\"}]", "[{\"id\":500, \"name\":\"500\"}]" }; DataStream source = env.fromElements(records); ``` It fails since connector wrapped the json array...

wuxueyang96