starrocks-connector-for-apache-flink

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

[Test] Add backticks to column identifiers to fix queries for column names with `.`

1

As title Not production ready yet - need to make this solution a little bit cleaner and ensure no regressions occur

ddesilva12

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

Jin-H

Synchronize ddl schema change to Starrocks by parsing json

chenhaifengkeda

支持flink catalog

6

不需要每个表定义 create table，方便使用. https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/#usage-of-jdbc-catalog doris 已经支持： https://github.com/apache/doris-flink-connector/pull/60/files @banmoy

melin

[Bugfix]: write nest json schema

2

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

Jin-H

[UT]: fix flink shaded guava class not found error in ut

1

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

Jin-H

At Present, synchronizing mysql data in real time takes two steps. Firstly, synchronize database & table schema with SMT. Secondly, synchronize data with Flink SQL. There are three areas for...

chenhaifengkeda

`StarRocksSourceFlinkRows` 类中的genFlinkRows()方法，循环体循环的是fieldVectors，这个应该是获取的表的所有字段长度可能会比selectedColumns选中的的字段要长，会导致后面出现数组索引越界。

qinxiang01

org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class com.starrocks.connector.flink.table.sink.StarRocksSinkRowDataWithMeta cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the...

minchowang

[Docs]: BINARY类型映射不对

2

### Link to the Docs [flink-connector-starrocks](https://docs.starrocks.io/zh/docs/loading/Flink-connector-starrocks/) ### Describe the Bug  估计是映射到： STRING VARCHAR BINARY ### Additional Info _No response_

hubble-insight