You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2020/03/01 23:55:35 UTC
[beam] branch master updated: Fix non correctly formatted class in
sdks/java/core
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 <ie...@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\""))));
}