1、使用异步算子,异步执行操作
2、将下游数据需要的数据以参数的形式向下传递
3、当服务器资源有限的情况下,慎用RocksDBStateBackend
RocksDBStateBackend performance will be poor because of the current Flink memory configuration! RocksDB wi…
DataStream API
参考:https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/datastream_api.html
Data Sources
Source是程序读取其输入的位置,您可以使用env.addSource(sourceFunction)将Source附加到程序中。Fl…