search

StarRocks / starrocks-connector-for-apache-flink

Apache License 2.0
192 stars 154 forks source link

flink-connector-starrocks 读取json字段异常，空指针？ #304

Open TonyHowardPark opened 10 months ago

TonyHowardPark commented 10 months ago
com.starrocks flink-connector-starrocks 1.2.3_flink-1.14_2.11

在类中报空指针（desc.getType()）异常，json字段的类型获取不到

public static StarRocksSchema genSchema(List tscanColumnDescs) { StarRocksSchema schema = new StarRocksSchema(); tscanColumnDescs.stream().forEach(desc -> schema.put( new Column(desc.getName(), desc.getType().name(), "", 0, 0)) ); return schema; }

需修改为以下代码，当字符串来处理：

public static StarRocksSchema genSchema(List tscanColumnDescs) { StarRocksSchema schema = new StarRocksSchema(); tscanColumnDescs.stream().forEach(desc -> schema.put( new Column(desc.getName(), desc.getType()==null? "VARCHAR": desc.getType().name(), "", 0, 0)) ); return schema; }

合适能支持json格式了？

TonyHowardPark commented 10 months ago
com.starrocks flink-connector-starrocks 1.2.3_flink-1.14_2.11
yogboot commented 10 months ago

你好，什么时候能支持flink读取starrocks表中的json列，现在1.2.8读取报错