Apache Beam java测试ExpectedLogs Maven

Question

我将ApacheBeam与Maven一起使用，并在pom中使用。依赖关系是xml

<dependency>
   <groupId>org.apache.beam</groupId>
   <artifactId>beam-sdks-java-core</artifactId>
   <version>2.8.0</version>
</dependency>

我可以用

import org.apache.beam.sdk.testing.PAssert;

但是我不能用

import org.apache.beam.sdk.testing.ExpectedLogs;

就像这里https://github.com/apache/beam/blob/master/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java

任何帮助都将不胜感激

Answer 1

这是因为org.apache.beam.sdk.testing.PAssert在beam-sdks-java-core中，而org.apache.beam.sdk.testing.ExpectedLogs在beam-sdks-java-core-test中

我不认为org.apache.beam.sdk.testing.ExpectedLogs被发布到Beam-maven工件中。您可以从https://github.com/apache/beam本地编译模块，并将其添加到maven项目中

要在本地编译beam-sdks-java-core-test，首先可以cd到Beam的父目录。然后运行命令./gradlew :beam-sdks-java-core:shadowTestJar。之后，您应该能够在sdks/java/core/build/libs中找到名为beam-sdks-java-core-2.10.0-SNAPSHOT-tests.jar的jar