Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. #30480
Job | Run time |
---|---|
1m 18s | |
19s | |
16m 38s | |
0s | |
15m 19s | |
14m 2s | |
25m 35s | |
23s | |
37s | |
26s | |
3m 49s | |
24s | |
19s | |
17s | |
5m 8s | |
57s | |
52s | |
0s | |
45s | |
49m 6s | |
0s | |
0s | |
0s | |
2h 16m 14s |