[flink] 05/05: [hotfix][filesystems] Remove unused StopWatch

[gary]

This is an automated email from the ASF dual-hosted git repository.

gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit efd22a7cfc53d083b6c02941641d8f17f1c767ea
Author: Gary Yao <g...@apache.org>
AuthorDate: Thu Apr 23 19:00:49 2020 +0200

    [hotfix][filesystems] Remove unused StopWatch
---
 .../flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java    | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
 
b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
index 05e8cd0..adf123f 100644
--- 
a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
+++ 
b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
@@ -29,7 +29,6 @@ import org.apache.flink.util.FlinkRuntimeException;
 import org.apache.flink.util.IOUtils;
 import org.apache.flink.util.Preconditions;
 
-import org.apache.commons.lang3.time.StopWatch;
 import org.apache.hadoop.fs.FSDataOutputStream;
 import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
@@ -332,9 +331,6 @@ class HadoopRecoverableFsDataOutputStream extends 
RecoverableFsDataOutputStream
 
                final Deadline deadline = 
Deadline.now().plus(Duration.ofMillis(LEASE_TIMEOUT));
 
-               final StopWatch sw = new StopWatch();
-               sw.start();
-
                boolean isClosed = dfs.isFileClosed(path);
                while (!isClosed && deadline.hasTimeLeft()) {
                        try {