This topic describes how to use Flink DataStream in an E-MapReduce (EMR) Dataflow cluster.
The Flink DataStream API in an EMR Dataflow cluster supports all features of the Apache Flink DataStream API. For more information about the Apache Flink DataStream API, see Flink DataStream API Programming Guide.
Upstream and downstream storages (connectors)
EMR V5.17.0 or a later minor version and EMR V3.51.0 or a later minor version
For information about upstream and downstream storages that are supported by Apache Flink, see DataStream Connectors.
A minor version earlier than EMR V5.17.0 or V3.51.0
The following table describes the upstream and downstream storages that are supported by Flink DataStream in an EMR Dataflow cluster.
Connector version
EMR version
Connector type
References and demo
1.13-vvr-4.0.10 or later
EMR V3.38.0 or a later minor version
ververica-connector-kafka
Reference: Kafka DataStream Connector
ververica-connector-odps
ververica-connector-continuous-odps
Reference: MaxCompute DataStream Connector
ververica-connector-mysql-cdc
Reference: MySQL CDC DataStream Connector