[beam] branch release-2.41.0 updated: Fix typo in Datastore V1ReadIT test

[ki...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kileysok pushed a commit to branch release-2.41.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.41.0 by this push:
     new 7386ae100c1 Fix typo in Datastore V1ReadIT test
7386ae100c1 is described below

commit 7386ae100c1a77a9cee3287704b50b5071d9f501
Author: Yixiao Shen <yi...@google.com>
AuthorDate: Thu Jul 28 00:29:04 2022 +0000

    Fix typo in Datastore V1ReadIT test
---
 .../src/test/java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java
index 7d6fc577038..249cadd4886 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java
@@ -172,7 +172,7 @@ public class V1ReadIT {
             .withReadTime(readTime);
 
     Pipeline p2 = Pipeline.create(options);
-    PCollection<Long> count2 = p.apply(snapshotRead).apply(Count.globally());
+    PCollection<Long> count2 = p2.apply(snapshotRead).apply(Count.globally());
 
     long expectedNumEntities2 = limit > 0 ? limit : numEntitiesBeforeReadTime;
     PAssert.thatSingleton(count2).isEqualTo(expectedNumEntities2);