beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From alexvanbo...@apache.org
Subject [beam] branch master updated: Fix non correctly formatted class in sdks/java/core
Date Sun, 01 Mar 2020 23:55:35 GMT
This is an automated email from the ASF dual-hosted git repository.

alexvanboxel pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 1d7453d  Fix non correctly formatted class in sdks/java/core
     new 753fd3f  Merge pull request #11010 from Fix non correctly formatted class in sdks/java/core
1d7453d is described below

commit 1d7453da96c858553bb0a401c13ddfa1209a09ae
Author: Ismaël Mejía <iemejia@gmail.com>
AuthorDate: Sun Mar 1 07:48:39 2020 +0100

    Fix non correctly formatted class in sdks/java/core
---
 .../test/java/org/apache/beam/sdk/transforms/ParDoTest.java    | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
index fa1e892..8b243f4 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
@@ -514,9 +514,7 @@ public class ParDoTest implements Serializable {
       SingleOutput<KV<String, String>, String> parDo = ParDo.of(fn);
 
       // Use the parDo in a pipeline to cause state coders to be inferred.
-      pipeline
-          .apply(Create.of(KV.of("input", "value")))
-          .apply(parDo);
+      pipeline.apply(Create.of(KV.of("input", "value"))).apply(parDo);
 
       DisplayData displayData = DisplayData.from(parDo);
       assertThat(
@@ -534,9 +532,9 @@ public class ParDoTest implements Serializable {
                   hasKey("state_map"),
                   hasType(DisplayData.Type.STRING),
                   hasValue(
-                      "MapState<StringUtf8Coder, " +
-                      "SerializableCoder(org.apache.beam.sdk.transforms.ParDoTest" +
-                      "$BasicTests$SerializableClass)>"),
+                      "MapState<StringUtf8Coder, "
+                          + "SerializableCoder(org.apache.beam.sdk.transforms.ParDoTest"
+                          + "$BasicTests$SerializableClass)>"),
                   hasLabel("State \"map\""))));
     }
 


Mime
View raw message