[BEAM-312] UnboundedSourceWrapper fails if CheckpointMarkCoder not available

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 0.1.0-incubating
• Fix Version/s: 0.1.0-incubating
• Component/s: runner-flink
• Assignee: Maximilian Michels
• Reporter: Maximilian Michels
• Created: 28/May/16 14:12
• Updated: 24/Jul/20 20:57
• Resolved: 30/May/16 10:23

Description

The Flink Runner's UnboundedSourceWrapper does not check whether the CheckpointMarkCoder is null. In this case, no checkpoint is required by the wrapped source.

  /**
   * 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();

We should skip checkpointing if no CheckpointMarkCoder is supplied.

Issue Links

• links to: GitHub Pull Request #395
• links to: GitHub Pull Request #395