Github user casidiablo commented on the issue: https://github.com/apache/flink/pull/4150 Since EMR only supports Flink 1.3 I had to checkout release-1.3 and compile the connector from there. Then I was getting this `Socket not created by this factory` error. I then patched 1.3 to include these changes, and that fixed it. The current master version can't be used because so many things have changed since then, and it does not seem to be compatible with EMR right now.
---