Hi In flink runner we have this code:
https://github.com/apache/incubator-beam/blob/master/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java#L262 but in mostly cases method startBundle can be expensive for making for every element (for example connection for db/build cache/ etc) Why so important invoke startBundle/finishBundle on every incoming streamRecord ? Thanks Alexey Diomin
