beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jingsong Lee (JIRA)" <>
Subject [jira] [Created] (BEAM-1612) Support real Bundle in Flink runner
Date Fri, 03 Mar 2017 06:33:54 GMT
Jingsong Lee created BEAM-1612:

             Summary: Support real Bundle in Flink runner
                 Key: BEAM-1612
             Project: Beam
          Issue Type: Improvement
          Components: runner-flink
            Reporter: Jingsong Lee
            Assignee: Jingsong Lee

The Bundle is very important in the beam model. Users can use the bundle to flush buffer,
can reuse many heavyweight resources in a bundle. Most IO plugins use the bundle to flush.

Moreover, FlinkRunner can also use Bundle to reduce access to the FlinkState, such as first
placed in JavaHeap, flush into RocksDbState when invoke finishBundle , this can reduce the
number of serialization.

But now FlinkRunner calls the finishBundle every processElement. We need support real Bundle.

I think we can have the following implementations:

1.Invoke finishBundle and next startBundle in {{snapshot}} of Flink. But sometimes this "Bundle"
maybe too big. This depends on the user's checkpoint configuration.

2.Manually control the size of the bundle. The half-bundle will be flushed to a full-bundle
by count or eventTime or processTime or {{snapshot}}. We do not need to wait, just call the
startBundle and finishBundle at the right time.

This message was sent by Atlassian JIRA

View raw message