Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. #28121
Job | Run time |
---|---|
12s | |
19m 46s | |
6m 35s | |
18m 21s | |
8m 28s | |
18m 4s | |
6m 33s | |
19m 2s | |
6m 49s | |
13m 29s | |
2m 27s | |
13m 38s | |
2m 43s | |
13m 22s | |
2m 43s | |
14m 26s | |
3m 12s | |
4m 29s | |
2m 48s | |
2m 46s | |
3m 36s | |
0s | |
0s | |
3h 3m 29s |