Hi all,
We just released Scio 0.8.3. This is mainly a bug fix release with some
minor improvements.
*Notes on JDK 11*
JDK 11 is now supported starting with 0.8.2. To upgrade, you'll need to
build your code and submit jobs to Dataflow with JDK 11.
*Notes on Scala 2.11*
Scio 0.8.x will be the last
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
