flink流具有多个数据流,然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案,但com.liam.learn.flink.example.union.UnionStreamDemo.SortFunction环境信息: flink版本1.7.0
Flink是否有避免每次提交作业时都上传扩展jars的配置,就像spark-submit中的spark.yarn.archive一样?我知道处理外部jars的方法,比如How to Reference the External Jar in Flink中的答案。例如fat jar、将jar复制到$FLINK/lib、-yt配置,但它们不够灵活或不够方便。