Issue with Event_Time Timer

[Steve Low <st...@gmail.com>]

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]