flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [6/8] flink git commit: [FLINK-4422] [clients] Convert time interval measurements to System.nanoTime() in 'flink-clients'
Date Thu, 16 Mar 2017 14:05:47 GMT
[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.phd@gmail.com>
Authored: Tue Feb 21 22:43:54 2017 +0800
Committer: Stephan Ewen <sewen@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();
 					}
 				}
 


Mime
View raw message