Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
0.10.2
-
None
-
None
Description
The implicit conversion from Seq to Flink DataStream needs to create internally a new execution environment.
This method is confusing to use. If one uses the Seq in a program that uses a different execution environment, then different streams run on different execution environments.
The overhead of manually calling env.fromElements(seq) is quite low.