Jackson-xky opened a new pull request, #20:
URL: https://github.com/apache/flink-connector-hbase/pull/20

   
HBaseRowDataLookupFunction.lookup中返回的结果是Collections.singletonList(serde.convertToNewRow(result)),这里默认都是用convertToNewRow方法,内部是在复用同一个对象,当开启了lookup.cache的时候,会导致缓存的结果只都是同一个对象,从而导致结果错乱,由于这里目前不能判断是否使用cache,因此只能默认使用convertToNewRow返回一个新对象来避免上面的情况


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to