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

Posted by liujiangang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/One-source-is-much-slower-than-the-other-side-when-join-history-data-tp26365.html

      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?