Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r158714573
--- Diff: storm-core/test/clj/org/apache/storm/nimbus_test.clj ---
@@ -792,15 +795,18 @@
(bind _ (log-message "ass1, t76, pre beat: " (pr-str ass1)))
(bind _ (log-message "ass2, t76, pre beat: " (pr-str ass2)))
(is (= ass1 (executor-assignment cluster storm-id executor-id1)))
- (is (not= ass2 (executor-assignment cluster storm-id executor-id2)))
+ ;TODO: fix local test of worker reports
+ ;(is (not= ass2 (executor-assignment cluster storm-id executor-id2)))
(bind ass2 (executor-assignment cluster storm-id executor-id2))
(bind _ (log-message "ass1, t76, post beat: " (pr-str ass1)))
(bind _ (log-message "ass2, t76, post beat: " (pr-str ass2)))
(check-consistency cluster "test")
(.advanceClusterTime cluster 31)
- (is (not= ass1 (executor-assignment cluster storm-id executor-id1)))
+ ;TODO: fix local test of worker reports
--- End diff --
fixed already
---
