[FLINK-4422] [clients] Convert time interval measurements to System.nanoTime() in 'flink-clients'
This closes #3384 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b5e1f68 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b5e1f68 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6b5e1f68 Branch: refs/heads/master Commit: 6b5e1f68a9b78901f0af57f446b465a7b03a88bd Parents: 70252f3 Author: Jin Mingjian <jin....@gmail.com> Authored: Tue Feb 21 22:43:54 2017 +0800 Committer: Stephan Ewen <se...@apache.org> Committed: Thu Mar 16 14:43:27 2017 +0100 ---------------------------------------------------------------------- .../org/apache/flink/client/program/ClientConnectionTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/6b5e1f68/flink-clients/src/test/java/org/apache/flink/client/program/ClientConnectionTest.java ---------------------------------------------------------------------- diff --git a/flink-clients/src/test/java/org/apache/flink/client/program/ClientConnectionTest.java b/flink-clients/src/test/java/org/apache/flink/client/program/ClientConnectionTest.java index 4eb5269..fc24a9d 100644 --- a/flink-clients/src/test/java/org/apache/flink/client/program/ClientConnectionTest.java +++ b/flink-clients/src/test/java/org/apache/flink/client/program/ClientConnectionTest.java @@ -115,13 +115,13 @@ public class ClientConnectionTest { try { // wait until the caller is successful, for at most the given time - long now = System.currentTimeMillis(); - long deadline = now + MAX_DELAY; + long now = System.nanoTime(); + long deadline = now + MAX_DELAY * 1_000_000; synchronized (error) { while (invoker.isAlive() && error.get() == null && now < deadline) { error.wait(1000); - now = System.currentTimeMillis(); + now = System.nanoTime(); } }
