Hello everyone! I have noticed that Jenkins tests for Dataflow runner [1] are failing with a runtime exception. It looks like the issue originated here [2], failed Dataflow job [3]. We should look into fixing it.
Failing test: :runners:google-cloud-dataflow-java:validatesRunnerLegacyWorkerTest » org.apache.beam.sdk.transforms.ParDoTest$TimerTests » testOutputTimestamp (29.723s) Exception thrown: java.lang.RuntimeException: Workflow failed. Causes: Unknown streaming source: test_stream [1] https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/ [2] https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4157/ [3] https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2020-01-08_14_36_07-180707589785292440?project=apache-beam-testing
