如何使用直接转轮在eclipse中调试数据流/Apache总线管道DoFn函数

Question

我希望在eclipse中使用直接转轮运行管道，并在DoFn函数和调试执行中放置一个断点。我尝试通过以下步骤设置直接运行程序：

1. 添加直接转轮maven包

​

1. 在pom.xml中为直接转轮设置maven配置文件。我的pom.xml有这份档案

<profiles> <profile> <id>direct-runner</id> <activation> <activeByDefault>true</activeByDefault> </activation> <dependencies> <dependency> <groupId>org.apache.beam</groupId> <artifactId>beam-runners-direct-java</artifactId> <version>0.2.0-incubating</version> </dependency> </dependencies> </profile> </profiles>

1. 我的pom.xml中有插件管理下的pom.xml maven插件

<pluginManagement> <plugins> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>exec-maven-plugin</artifactId> <version>1.4.0</version> <executions> <execution> <goals> <goal>java</goal> </goals> </execution> </executions> <configuration> <cleanupDaemonThreads>false</cleanupDaemonThreads> <mainClass>com.MyMainClass</mainClass> </configuration> </plugin> </plugins> </pluginManagement>

1. 下面是eclipse调试配置的屏幕截图。

当我使用上面的调试配置作业运行时，将在GCP数据流中启动，而不是本地JVM线程，并且我的断点永远不会被击中。

Answer 1

可能是在测试方法中创建管道的方式。尝试使用TestPipeline util类创建管道，如下所示

public TestPipeline p = TestPipeline.create();