[
https://issues.apache.org/jira/browse/BEAM-306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300583#comment-15300583
]
Kenneth Knowles commented on BEAM-306:
--------------------------------------
I think there's a confusing ambiguity at [this line in
UnboundedSource|https://github.com/apache/incubator-beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java#L213]
in the spec for getting a checkpoint.
"The returned object should not be modified."
By whom? We can't say that it applies to everyone, since the interface for the
checkpoint includes a finalization method. I think the most reasonable
interpretation (and anyhow the one that seems obvious anyhow) is that once the
object is returned, the source no longer owns it; the context owns it. So the
source should not hang on to it, or at least should not do anything observable
with it. But [[email protected]] and [[email protected]] might have a
different idea.
> Make java-only PubsubIO work in InProcessRunner
> ------------------------------------------------
>
> Key: BEAM-306
> URL: https://issues.apache.org/jira/browse/BEAM-306
> Project: Beam
> Issue Type: Bug
> Components: runner-core
> Reporter: Mark Shields
> Assignee: Mark Shields
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
