beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echauc...@apache.org
Subject [beam] 37/45: Clean groupByKeyTest
Date Tue, 09 Jul 2019 13:18:54 GMT
This is an automated email from the ASF dual-hosted git repository.

echauchot pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git

commit bea2c60e124e4858657ff30c9d67a08fd7ebddb6
Author: Etienne Chauchot <echauchot@apache.org>
AuthorDate: Thu Jul 4 15:08:12 2019 +0200

    Clean groupByKeyTest
---
 .../spark/structuredstreaming/translation/batch/GroupByKeyTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/GroupByKeyTest.java
b/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/GroupByKeyTest.java
index c95d07d..6e20164 100644
--- a/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/GroupByKeyTest.java
+++ b/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/GroupByKeyTest.java
@@ -59,7 +59,7 @@ public class GroupByKeyTest implements Serializable {
 
   @Test
   public void testGroupByKeyPreservesWindowing(){
-    PCollection<KV<Integer, Iterable<Integer>>> input = p.apply(Create
+    p.apply(Create
         .timestamped(
             TimestampedValue.of(KV.of(1, 1), new Instant(1)),
             TimestampedValue.of(KV.of(1, 3), new Instant(2)),
@@ -90,8 +90,8 @@ public class GroupByKeyTest implements Serializable {
           }
         }));
     p.run();
-
   }
+
   @Test
   public void testGroupByKey() {
     List<KV<Integer, Integer>> elems = new ArrayList<>();


Mime
View raw message