[ https://issues.apache.org/jira/browse/BEAM-5521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175440#comment-17175440 ]
Maximilian Michels commented on BEAM-5521: ------------------------------------------ If I'm not mistaken this has already been fixed by introducing a cache for process bundle descriptors. CC [~robertwb] > Cache execution trees in SDK worker > ----------------------------------- > > Key: BEAM-5521 > URL: https://issues.apache.org/jira/browse/BEAM-5521 > Project: Beam > Issue Type: Improvement > Components: sdk-py-harness > Reporter: Robert Bradshaw > Priority: P2 > Labels: portability-flink, stale-P2 > Time Spent: 40m > Remaining Estimate: 0h > > Currently they are re-constructed from the protos for every bundle, which is > expensive (especially for 1-element bundles in streaming flink). > Care should be taken to ensure the objects can be re-usued. -- This message was sent by Atlassian Jira (v8.3.4#803005)