Hi Guys I am doing experiment with apache beam event time timer, The pipeline receive message from pubsubIO , convert pubsub message to a result object , then pass to a DoFn SortedByKey , in which i would expect a message "expired" to print out and output a string "done" to TextIO . But it did not , I could not figure out why nor how to troubleshoot it . Does anyone has any idea ?
See my test project: https://github.com/stevenextwave/beam mvn clean test [INFO] ------------------------------------------------------- [INFO] T E S T S [INFO] ------------------------------------------------------- [INFO] Running org.apache.beam.examples.test.EndToEndTest Mar 20, 2020 10:06:45 PM org.apache.beam.examples.test.Helper$1 onSuccess INFO: Sending Id =19 Mar 20, 2020 10:06:51 PM org.apache.beam.examples.PubSubToResult processElement INFO: recv={"id":"43808a78-8af4-4caa-afdb-91f30a6668b7","payload":"testmesssge"} Mar 20, 2020 10:06:52 PM org.apache.beam.examples.SortedByKey processElement INFO: set timer2020-03-20T14:06:59.999Z [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 46.443 s - in org.apache.beam.examples.test.EndToEndTest [INFO]
