Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. #30408
Job | Run time |
---|---|
41s | |
14s | |
1m 48s | |
0s | |
1m 49s | |
1m 48s | |
1m 46s | |
22s | |
24s | |
26s | |
1m 44s | |
16s | |
15s | |
16s | |
1m 37s | |
53s | |
0s | |
1m 36s | |
1m 34s | |
1m 48s | |
1s | |
1s | |
1s | |
19m 20s |