From 2b45dd01dceddf8f382e4ca3ef65663eec1b01b3 Mon Sep 17 00:00:00 2001 From: Reuven Lax Date: Thu, 2 May 2019 11:06:43 -0700 Subject: [PATCH] Fix non-determistic row access --- .../java/org/apache/beam/sdk/transforms/ParDoSchemaTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoSchemaTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoSchemaTest.java index 9408fc35012cb..3d1415d0ca32c 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoSchemaTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoSchemaTest.java @@ -388,7 +388,7 @@ public void testInferredSchemaPipeline() { new DoFn() { @ProcessElement public void process(@Element Row row, OutputReceiver r) { - r.output(row.getString(0) + ":" + row.getInt32(1)); + r.output(row.getString("stringField") + ":" + row.getInt32("integerField")); } })); PAssert.that(output).containsInAnyOrder("a:1", "b:2", "c:3");