You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yi...@apache.org on 2021/12/03 21:23:11 UTC

[beam] branch master updated: Fix failing RecommendationAICatalogItemIT

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

yichi 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 3c948fc  Fix failing RecommendationAICatalogItemIT
     new 89e2b23  Merge pull request #16132 from y1chi/fix_post
3c948fc is described below

commit 3c948fc1476c7e2b3ef97380b8931452c33f90d1
Author: Yichi Zhang <zy...@google.com>
AuthorDate: Fri Dec 3 11:24:25 2021 -0800

    Fix failing RecommendationAICatalogItemIT
---
 .../apache/beam/sdk/extensions/ml/RecommendationAICatalogItemIT.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAICatalogItemIT.java b/sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAICatalogItemIT.java
index 4d45bc4..00e70d9 100644
--- a/sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAICatalogItemIT.java
+++ b/sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAICatalogItemIT.java
@@ -38,15 +38,15 @@ import org.apache.beam.sdk.transforms.SerializableFunction;
 import org.apache.beam.sdk.values.KV;
 import org.apache.beam.sdk.values.PCollectionTuple;
 import org.junit.AfterClass;
+import org.junit.ClassRule;
 import org.junit.Ignore;
-import org.junit.Rule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
 @RunWith(JUnit4.class)
 public class RecommendationAICatalogItemIT {
-  @Rule public static TestPipeline testPipeline = TestPipeline.create();
+  @ClassRule public static TestPipeline testPipeline = TestPipeline.create();
   private static String projectId = testPipeline.getOptions().as(GcpOptions.class).getProject();
   private static final String randomId =
       "aitest-" + Instant.now().getEpochSecond() + UUID.randomUUID().toString();