You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/12/04 07:48:18 UTC
[flink] branch master updated: [FLINK-11047] Fix
CoGroupGroupSortTranslationTest by specyfing types
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new d02c48a [FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types
d02c48a is described below
commit d02c48a739591bb80ae44a2742100f03378871c2
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Mon Dec 3 11:46:13 2018 +0100
[FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types
Adding the parameter types is necessary to compile the CoGroupGroupSortTranslationTest
with Scala 2.12.
---
.../operators/translation/CoGroupGroupSortTranslationTest.scala | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CoGroupGroupSortTranslationTest.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CoGroupGroupSortTranslationTest.scala
index bf07aa0..1d571d0 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CoGroupGroupSortTranslationTest.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CoGroupGroupSortTranslationTest.scala
@@ -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()