[
https://issues.apache.org/jira/browse/BEAM-312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed BEAM-312.
-----------------------------------
Resolution: Fixed
Fixed with 5d2f9cd29b1ea70b3e6bbd5c884260c3695262d3
> UnboundedSourceWrapper fails if CheckpointMarkCoder not available
> -----------------------------------------------------------------
>
> Key: BEAM-312
> URL: https://issues.apache.org/jira/browse/BEAM-312
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Affects Versions: 0.1.0-incubating
> Reporter: Maximilian Michels
> Assignee: Maximilian Michels
> Fix For: 0.1.0-incubating
>
>
> The Flink Runner's UnboundedSourceWrapper does not check whether the
> CheckpointMarkCoder is null. In this case, no checkpoint is required by the
> wrapped source.
> {noformat}
> /**
> * Returns a {@link Coder} for encoding and decoding the checkpoints for
> this source, or
> * null if the checkpoints do not need to be durably committed.
> */
> @Nullable
> public abstract Coder<CheckpointMarkT> getCheckpointMarkCoder();
> {noformat}
> We should skip checkpointing if no CheckpointMarkCoder is supplied.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
