Hi All I have created this PR to upgrade 0.2.0-release to use Flink 1.1.2. There are some nice features added in Flink 1.1.2 which we cannot consume until Beam supports it. I know that Flink 1.1.2 will be supported in 0.3.0. But for time being, we don't want to add a dependency on a snapshot version.
Would love to hear your feedback and views on this one.. Regards Sumit Chawla
