Skip to content

Commit

Permalink
[runners-flink] apache#28258 Wait infinitely if the duration value is…
Browse files Browse the repository at this point in the history
… less than 1ms in FlinkDetachedRunnerResult
  • Loading branch information
ddebowczyk92 authored and kennknowles committed Sep 22, 2023
1 parent 4515617 commit bd368f3
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ public State waitUntilFinish(Duration duration) {
long start = System.currentTimeMillis();
long durationInMillis = duration.getMillis();
State state = State.UNKNOWN;
while ((System.currentTimeMillis() - start) < durationInMillis) {
while (durationInMillis < 1 || (System.currentTimeMillis() - start) < durationInMillis) {
state = getState();
if (state.isTerminal()) {
return state;
Expand Down

0 comments on commit bd368f3

Please sign in to comment.