One source is much slower than the other side when join history data

[刘建刚]

      When consuming history data in join operator with eventTime, reading
data from one source is much slower than the other. As a result, the join
operator will cache much data from the faster source in order to wait the
slower source.
      The question is that how can I make the difference of consumers'
speed small?