Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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

...