Skip to content
This repository has been archived by the owner on Jan 6, 2023. It is now read-only.

Commit

Permalink
Skip input recovery when resume mode is :initialize (#872)
Browse files Browse the repository at this point in the history
  • Loading branch information
@sundbry @lbradstreet
sundbry authored and lbradstreet committed Sep 27, 2018
1 parent 0f7b342 commit 8d3c56f
Showing 1 changed file with 5 additions and 6 deletions.
11 changes: 5 additions & 6 deletions src/onyx/peer/resume_point.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -111,10 +111,9 @@
{:keys [onyx.core/slot-id]} event]
(checkpoint-decompress (read-checkpoint event :output resume-mapping slot-id)))))

(defn recover-input [event recover-coordinates]
(if-let [resume-mapping (coordinates->input-resume-point event recover-coordinates)]
(let [{:keys [slot-migration]} resume-mapping
;; TODO, support slot-id mappings
_ (assert (= slot-migration :direct))
{:keys [onyx.core/slot-id]} event]
(defn recover-input [{:keys [onyx.core/slot-id] :as event} recover-coordinates]
(when-let [{:keys [mode slot-migration] :as resume-mapping} (coordinates->input-resume-point event recover-coordinates)]
(when (not= mode :initialize)
;; TODO, support slot-id mappings
(assert (= slot-migration :direct))
(checkpoint-decompress (read-checkpoint event :input resume-mapping slot-id)))))

0 comments on commit 8d3c56f

Please sign in to comment.