[FLINK-21959] Shorten kinesis egress/ingress
4 files changed