You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jo...@apache.org on 2022/11/29 15:08:29 UTC
[beam] branch master updated: Fix SparkReceiverIOIT test (#24375)
This is an automated email from the ASF dual-hosted git repository.
johncasey 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 4b959e73a71 Fix SparkReceiverIOIT test (#24375)
4b959e73a71 is described below
commit 4b959e73a71fafa70bac175243e78c309786a4f8
Author: Vitaly Terentyev <vi...@akvelon.com>
AuthorDate: Tue Nov 29 19:08:13 2022 +0400
Fix SparkReceiverIOIT test (#24375)
---
sdks/java/io/sparkreceiver/2/build.gradle | 1 +
.../apache/beam/sdk/io/sparkreceiver/SparkReceiverIOIT.java | 12 +-----------
2 files changed, 2 insertions(+), 11 deletions(-)
diff --git a/sdks/java/io/sparkreceiver/2/build.gradle b/sdks/java/io/sparkreceiver/2/build.gradle
index 52c6a634049..7607127adca 100644
--- a/sdks/java/io/sparkreceiver/2/build.gradle
+++ b/sdks/java/io/sparkreceiver/2/build.gradle
@@ -37,6 +37,7 @@ configurations.all {
exclude group: 'org.slf4j', module: 'slf4j-jdk14'
exclude group: 'org.slf4j', module: 'slf4j-log4j12'
exclude group: 'org.slf4j', module: 'slf4j-reload4j'
+ exclude group: "org.slf4j", module: "jul-to-slf4j"
}
dependencies {
diff --git a/sdks/java/io/sparkreceiver/2/src/test/java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIOIT.java b/sdks/java/io/sparkreceiver/2/src/test/java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIOIT.java
index b335aab2ed5..4f839fc7c5d 100644
--- a/sdks/java/io/sparkreceiver/2/src/test/java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIOIT.java
+++ b/sdks/java/io/sparkreceiver/2/src/test/java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIOIT.java
@@ -49,12 +49,9 @@ import org.apache.beam.sdk.metrics.Counter;
import org.apache.beam.sdk.metrics.Metrics;
import org.apache.beam.sdk.options.Default;
import org.apache.beam.sdk.options.Description;
-import org.apache.beam.sdk.options.ExperimentalOptions;
-import org.apache.beam.sdk.options.PipelineOptionsFactory;
import org.apache.beam.sdk.options.StreamingOptions;
import org.apache.beam.sdk.options.Validation;
import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.TestPipelineOptions;
import org.apache.beam.sdk.testutils.NamedTestResult;
import org.apache.beam.sdk.testutils.metrics.IOITMetrics;
import org.apache.beam.sdk.testutils.metrics.MetricsReader;
@@ -113,14 +110,7 @@ public class SparkReceiverIOIT {
private static InfluxDBSettings settings;
- private static final ExperimentalOptions sdfPipelineOptions;
-
- static {
- sdfPipelineOptions = PipelineOptionsFactory.create().as(ExperimentalOptions.class);
- sdfPipelineOptions.as(TestPipelineOptions.class).setBlockOnRun(false);
- }
-
- @Rule public TestPipeline readPipeline = TestPipeline.fromOptions(sdfPipelineOptions);
+ @Rule public TestPipeline readPipeline = TestPipeline.create();
@BeforeClass
public static void setup() throws IOException {