StarRocks / starrocks-connector-for-apache-flink

Apache License 2.0
189 stars 152 forks source link

【BUG】【Lookup Join】在使用StarRocks连接器做lookup join 的时候,select的字段必须要和表字段一样 #331

Open qinxiang01 opened 7 months ago

qinxiang01 commented 7 months ago

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

image