@Override
  public Coder<SyntheticRecordsCheckpoint> getCheckpointMarkCoder() {
    return SyntheticRecordsCheckpoint.CODER;
  }
@Test
  public void checkpointCoderShouldBeSane() {
    CoderProperties.coderSerializable(source.getCheckpointMarkCoder());
  }