Skip to content

Commit

Permalink
[FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types
Browse files Browse the repository at this point in the history
Adding the parameter types is necessary to compile the CoGroupGroupSortTranslationTest
with Scala 2.12.
  • Loading branch information
tillrohrmann committed Dec 4, 2018
1 parent 63a6a0e commit d02c48a
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,11 @@ class CoGroupGroupSortTranslationTest extends TestLogger {
.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)))
.apply(
(a: Iterator[(Long, Long)],
b: Iterator[(Long, Long, Long)],
c: Collector[(Long, Long)]) =>
a.foreach(e => c.collect(e)))
.output(new DiscardingOutputFormat[(Long, Long)])

val p = env.createProgramPlan()
Expand Down

0 comments on commit d02c48a

Please sign in to comment.