THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
I in my small prototype I ran the following tests (which are mostly non-complex queries):
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinks1
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinks2
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinks3
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinks4
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinks5
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinksWithUDTF
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinksSplitOnUnion1
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinksSplitOnUnion2
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinksSplitOnUnion3
- org.apache.flink.table.planner.plan.stream.sql.DagOptimizationTest#testMultiSinksSplitOnUnion4
...