[FLINK-5272] Refactor the stream Scala-expression Table API tests

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.4.0
• Component/s: Table SQL / API
• Assignee: sunjincheng
• Reporter: Fabian Hueske
• Created: 07/Dec/16 10:51
• Updated: 16/Nov/17 10:41
• Resolved: 16/Nov/17 10:41

Description

Most tests of the streaming Scala Table API tests are full-blown integration tests which are rather expensive to execute.

Most of tests should be converted into unit tests that validate the resulting execution plan (consisting of DataStreamRel nodes) based on the TableTestBase class.

In addition we need a few integration tests that check the translation from the optimized DataStreamRel plan to a DataStream program. These tests should be implemented by extending the StreamingMultipleProgramsTestBase and be located in few classes to avoid repeated instantiations of the FLink MiniCluster.

These tests must cover the translation process of each DataStreamRel operator.