New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-8959][tests] Port AccumulatorLiveITCase to flip6 #5719
Conversation
msg = (TestingJobManagerMessages.UpdatedAccumulators) receiveOne(TIMEOUT); | ||
try { | ||
NotifyingMapper.notifyLatch.await(); | ||
Thread.sleep(HEARTBEAT_INTERVAL * 4); // wait for heartbeat |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Isn't this test-flakiness waiting to happen? We could run this in a loop and wait until the accumulators are available with a Deadline
. If getAccumulators()
returned a Future we could even use the utilities in FutureUtils
, but can't fix that now, unfortunately... 😓
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Well....yeah we could use a deadline and polling, probably will be even faster.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@aljoscha Done; also found a way to make use of FutureUtils
.
Looks good now, when travis is green! 👌 |
Good work @zentol. I guess only a rebase is missing. +1 for merging then. |
merging. |
Based on #5701.
What is the purpose of the change
This PR ports the
AccumulatorLiveITCase
to flip6. The existing test was renamed toLegacyAccumulatorLiveITCase
, and a ported copy was added.The heartbeat interval is not configurable for legacy clusters and is hard-coded to 5 seconds. Porting this test (in a reliable fashion) without relying on internal/test APIs would've increased the test duration, so I decided to just leave it as it is.