http://git-wip-us.apache.org/repos/asf/flink/blob/18e7f2f4/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala b/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala index f300547..c56ab92 100644 --- a/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala +++ b/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala @@ -77,7 +77,6 @@ class ExpressionsITCase( TestBaseUtils.compareResultAsText(results.asJava, expected) } - // advanced functions not supported yet @Ignore @Test def testCaseInsensitiveForAs(): Unit = {
http://git-wip-us.apache.org/repos/asf/flink/blob/18e7f2f4/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/GroupedAggregationsITCase.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/GroupedAggregationsITCase.scala b/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/GroupedAggregationsITCase.scala index 50ce150..82c4dc2 100644 --- a/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/GroupedAggregationsITCase.scala +++ b/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/GroupedAggregationsITCase.scala @@ -46,7 +46,7 @@ class GroupedAggregationsITCase(mode: TestExecutionMode) extends MultipleProgram TestBaseUtils.compareResultAsText(results.asJava, expected) } - @Test(expected = classOf[NotImplementedError]) + @Test def testGroupedAggregate(): Unit = { // the grouping key needs to be forwarded to the intermediate DataSet, even @@ -62,7 +62,7 @@ class GroupedAggregationsITCase(mode: TestExecutionMode) extends MultipleProgram TestBaseUtils.compareResultAsText(results.asJava, expected) } - @Test(expected = classOf[NotImplementedError]) + @Test def testGroupingKeyForwardIfNotUsed(): Unit = { // the grouping key needs to be forwarded to the intermediate DataSet, even @@ -78,7 +78,7 @@ class GroupedAggregationsITCase(mode: TestExecutionMode) extends MultipleProgram TestBaseUtils.compareResultAsText(results.asJava, expected) } - @Test(expected = classOf[NotImplementedError]) + @Test def testGroupNoAggregation(): Unit = { val env = ExecutionEnvironment.getExecutionEnvironment
