by changing the right_col handle logic in join in datastream... needs tests to make sure it work properly