Skip to content

Commit

Permalink
[FLINK-3080] Relax restrictions of DataStream.union()
Browse files Browse the repository at this point in the history 
Before, it would not allow unioning with predecessors (also transitive)
and streams of differing parallelism.
  • Loading branch information
@aljoscha
aljoscha committed Dec 2, 2015
1 parent f8b456b commit 04b3802
Show file tree
Hide file tree
Showing 6 changed files with 333 additions and 195 deletions.
Loading

0 comments on commit 04b3802

Please sign in to comment.