This topic describes how to migrate self-managed Flink jobs. It covers three migration scenarios: migrating a Table/SQL JAR job to a SQL job, migrating a Datastream JAR job, and migrating a Table/SQL JAR job to a JAR job.
Background information
This topic uses an example to explain how to migrate self-managed Flink jobs. The example job calculates the total number of orders and the total order amount within a 5 minute window. To demonstrate this, the logic is implemented on a self-managed cluster using both a Datastream demo and a Table/SQL demo. You can download the code samples. The downloaded files are as follows:
Table/SQL: TableJobKafka2Rds.java
Datastream: DataStreamJobKafka2Rds.java
References
For more information, see Table/SQL & DataStream JAR job migration.
该文章对您有帮助吗？