flink 中connect后，操作两条流的数据

参考：

https://blog.csdn.net/weixin_42155491/article/details/105333833

使用process，自定义CoProcessFunction

使用state记录两条流的数据，

在process1中，判断数据2是否存在，存在则collect，不存在则开启timer

文章中timer的时间写法有问题

应该用context.timestamp()+Time.seconds(5).toMilliseconds

但是前提是 env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);

参考 http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ingesting-time-for-TimeCharacteristic-IngestionTime-on-unit-test-td26773.html#a26893