[FLINK-13708][table-planner-blink] Revert changes in fb7beb8 which is…

… a temporary fix
arne-klein · Nov 22, 2019 · f01cdd1 · f01cdd1
1 parent 23c9b5a
commit f01cdd1
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/...ink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java b/...ink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java
@@ -39,7 +39,7 @@ public class BatchAbstractTestBase {
 			new MiniClusterResourceConfiguration.Builder()
 					.setConfiguration(getConfiguration())
 					.setNumberTaskManagers(1)
-					.setNumberSlotsPerTaskManager(DEFAULT_PARALLELISM * 2) // TODO: Revert once FLINK-13708 has been fixed
+					.setNumberSlotsPerTaskManager(DEFAULT_PARALLELISM)
 					.build());
 
 	@ClassRule

diff --git a/...test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/AggregateITCaseBase.scala b/...test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/AggregateITCaseBase.scala
@@ -326,10 +326,6 @@ abstract class AggregateITCaseBase(testName: String) extends BatchTestBase {
       "select f0, count(*) from TableName group by f0",
       Seq((1, 2L), (2, 2L), (3, 2L)) // count=>long
     )
-  }
-
-  @Test
-  def testGroupBy2(): Unit = {
     checkQuery(
       Seq(("a", 1, 0), ("b", 2, 4), ("a", 2, 3)),
       "select f0, min(f1), min(f2) from TableName group by f0",