scwhittle
scwhittle
Run Java PreCommit
Do you know how to run a test 100x to verify it isn't flaky? I'm not sure if there is a gradle invocation to do that or not. Maybe @Abacn...
waiting on author
@arvindram03 friendly ping on above
Just made final edit (replace anyOf with allOf instead of separate allOf) instead of round-trip. Will merge once tests pass
Run Java_GCP_IO_Direct
I believe this is a long-standing bug within the python sdk. Side inputs within the global window are cached in [PerWindowInvoker](https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/common.py#L948) without respecting the side input cache token. This is...
@AnandInguva Can you verify the above fixes your issue? It does for my separate testing pipeline
Note that the fix was put behind an experiment due to potential performance concerns in cases where refreshing was undesired and the short time frame to get the original PR...
Without the sdk cache enabled (not on by default), removing the PerWindowInvoker cache mans that there is lots of FnApi traffic to fetch side inputs which contributed to latency in...