[hotfix] Let CoGroupGroupSortTranslationTest extend TestLogger and fi…

…x testGroupSortTuplesDefaultCoGroup

flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CoGroupGroupSortTranslationTest.scala

@@ -18,22 +18,15 @@
 
 package org.apache.flink.api.scala.operators.translation
 
-import org.apache.flink.api.java.io.DiscardingOutputFormat
-import org.apache.flink.optimizer.util.CompilerTestBase
-import org.junit.Assert._
-import org.junit.Test
-import org.apache.flink.api.common.functions.Partitioner
-import org.apache.flink.api.scala._
-import org.apache.flink.runtime.operators.shipping.ShipStrategyType
-import org.apache.flink.optimizer.plan.SingleInputPlanNode
 import org.apache.flink.api.common.operators.Order
-import org.apache.flink.api.common.InvalidProgramException
-import org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint
-import org.apache.flink.optimizer.plan.DualInputPlanNode
 import org.apache.flink.api.common.operators.base.CoGroupOperatorBase
-import org.junit.Ignore
+import org.apache.flink.api.java.io.DiscardingOutputFormat
+import org.apache.flink.api.scala._
+import org.apache.flink.util.{Collector, TestLogger}
+import org.junit.Assert._
+import org.junit.{Ignore, Test}
 
-class CoGroupGroupSortTranslationTest {
+class CoGroupGroupSortTranslationTest extends TestLogger {
 
  @Test
  def testGroupSortTuples() {
@@ -131,11 +124,12 @@ class CoGroupGroupSortTranslationTest {
  val input2 = env.fromElements( (0L, 0L, 0L) )
 
  input1
- .coGroup(input2)
- .where(1).equalTo(2)
- .sortFirstGroup(0, Order.DESCENDING)
- .sortSecondGroup(1, Order.ASCENDING).sortSecondGroup(0, Order.DESCENDING)
- .print()
+ .coGroup(input2)
+ .where(1).equalTo(2)
+ .sortFirstGroup(0, Order.DESCENDING)
+ .sortSecondGroup(1, Order.ASCENDING).sortSecondGroup(0, Order.DESCENDING)
+ .apply((a, b, c: Collector[(Long, Long)]) => a.foreach(e => c.collect(e)))
+ .output(new DiscardingOutputFormat[(Long, Long)])
 
  val p = env.createProgramPlan()