[hotfix][filesystems] Remove unused StopWatch

derekm · Apr 24, 2020 · efd22a7 · efd22a7
1 parent f9c23a0
commit efd22a7
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...s/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java b/...s/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
@@ -29,7 +29,6 @@
 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 @@ private static boolean waitUntilLeaseIsRevoked(final FileSystem fs, final Path p
 
  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 {