[beam] branch master updated: [BEAM-13430] Fix class not found error for example integration tests and dataflow postcommit (#16388)

[lcwik]

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

lcwik 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 df26931  [BEAM-13430] Fix class not found error for example 
integration tests and dataflow postcommit (#16388)
df26931 is described below

commit df2693175f9f4dcd14022196e3ed17b383728a30
Author: Yichi Zhang <zyi...@google.com>
AuthorDate: Thu Dec 30 10:37:34 2021 -0800

    [BEAM-13430] Fix class not found error for example integration tests and 
dataflow postcommit (#16388)
---
 .../java/src/test/java/org/apache/beam/examples/complete/TfIdfIT.java   | 2 +-
 .../java/org/apache/beam/examples/cookbook/BigQueryTornadoesIT.java     | 2 +-
 runners/google-cloud-dataflow-java/build.gradle                         | 2 ++
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfIT.java 
b/examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfIT.java
index 64fdd79..0b2575e 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfIT.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfIT.java
@@ -52,7 +52,7 @@ public class TfIdfIT {
 
   @BeforeClass
   public static void setUp() {
-    PipelineOptionsFactory.register(TfIdfITOptions.class);
+    PipelineOptionsFactory.register(TestPipelineOptions.class);
   }
 
   @Test
diff --git 
a/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesIT.java
 
b/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesIT.java
index 660dbcb..56380e5 100644
--- 
a/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesIT.java
+++ 
b/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesIT.java
@@ -60,7 +60,7 @@ public class BigQueryTornadoesIT {
 
   @BeforeClass
   public static void setUp() {
-    PipelineOptionsFactory.register(BigQueryTornadoesITOptions.class);
+    PipelineOptionsFactory.register(TestPipelineOptions.class);
   }
 
   private void runE2EBigQueryTornadoesTest(BigQueryTornadoesITOptions options) 
throws Exception {
diff --git a/runners/google-cloud-dataflow-java/build.gradle 
b/runners/google-cloud-dataflow-java/build.gradle
index b72bbff..9caed16 100644
--- a/runners/google-cloud-dataflow-java/build.gradle
+++ b/runners/google-cloud-dataflow-java/build.gradle
@@ -125,8 +125,10 @@ dependencies {
   coreSDKJavaIntegrationTest project(project.path)
   coreSDKJavaIntegrationTest project(path: ":sdks:java:core", configuration: 
"shadowTest")
   examplesJavaIntegrationTest project(project.path)
+  examplesJavaIntegrationTest project(":examples:java")
   examplesJavaIntegrationTest project(path: ":examples:java", configuration: 
"testRuntimeMigration")
   googleCloudPlatformIntegrationTest project(project.path)
+  googleCloudPlatformIntegrationTest 
project(":sdks:java:io:google-cloud-platform")
   googleCloudPlatformIntegrationTest project(path: 
":sdks:java:io:google-cloud-platform", configuration: "testRuntimeMigration")
 }