0

我正在为流式数据流作业编写 JobTest。

JobTest("className")
      .args("--config=conf/test.conf")
      .input(PubsubIO.readPubsub[PubsubMessage]("in"), Seq(new PubsubMessage(" ".getBytes()), null)))
      .output(BigQueryIO[T](tableName)) {f => f should haveSize(1)}
      .run()

现在我可以启动数据流作业，但它不会使用来自 pubsub 的消息测试消息。如何改进测试以读取通过 JobTest 发送的自定义消息？

另外我有一个连续运行的流式数据流作业，如何确保我触发的测试作业在运行测试后耗尽？

4

0 回答 0