@mxm We do plan to contribute the efforts of consuming from dynamodb streams (Flink-4582) back to upstream flink. This patch is needed for our internal testing. And we strive to keep upstream flink and our internal fork as consistent as possible.
[ Full content available at: https://github.com/apache/flink/pull/6708 ] This message was relayed via gitbox.apache.org for [email protected]
