src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java [154:162]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      if (this.commitMapTaskCommitStatus == null) {
        throw new RssInvalidDataException("MapTaskCommitStatus should not be null");
      }
      this.commitTaskAttemptIds = new HashSet<>(this.commitMapTaskCommitStatus.getTaskAttemptIds().values());
      if (!this.commitTaskAttemptIds.containsAll(fetchTaskAttemptIds)) {
        throw new RssInvalidDataException(String.format(
            "Task attempt ids not matched, committed: %s, fetching: %s",
            this.commitTaskAttemptIds,
            fetchTaskAttemptIds));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java [221:229]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    if (this.commitMapTaskCommitStatus == null) {
      throw new RssInvalidDataException("MapTaskCommitStatus should not be null");
    }
    this.commitTaskAttemptIds = new HashSet<>(this.commitMapTaskCommitStatus.getTaskAttemptIds().values());
    if (!this.commitTaskAttemptIds.containsAll(fetchTaskAttemptIds)) {
      throw new RssInvalidDataException(String.format(
          "Task attempt ids not matched, committed: %s, fetching: %s",
          this.commitTaskAttemptIds,
          fetchTaskAttemptIds));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -