Arun Pandian

icon location Seattle

Results 6 comments of Arun Pandian

Recurrence Missing instances if bymonthday is not sorted

@mschroeder yeah, i can look into it.

[Dataflow Streaming] Micro Optimizations

.take-issue

add shutdown and start mechanics to windmill streams

Like how there was a race between populating `pending` maps and shutdown, I think there is a race between mutating/accessing `batches` and shutdown in GrpcGetDataStream. Other pieces look okay to...

[Dataflow Streaming] Move timer tag logic to WindmillStateTagUtil

R: @scwhittle

[Dataflow Streaming] Move timer tag logic to WindmillStateTagUtil

@scwhittle can this be merged?

[Do not Merge] [WIP] Combine.perKeyWithBucketing: Combiner for reducing key cardinality

Closing this in favor of https://github.com/apache/beam/pull/33318