[hotfix][hdfs] Fixed error message when using HadoopRecoverableWriter…

… on non hdfs.
tongcheng-elong · Mar 2, 2020 · 0cfbe1f · 0cfbe1f
1 parent f0bdf31
commit 0cfbe1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableWriter.java b/...ink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableWriter.java
@@ -59,7 +59,7 @@ public HadoopRecoverableWriter(org.apache.hadoop.fs.FileSystem fs) {
  // This writer is only supported on a subset of file systems
  if (!"hdfs".equalsIgnoreCase(fs.getScheme())) {
  throw new UnsupportedOperationException(
- "Recoverable writers on Hadoop are only supported for HDFS and for Hadoop version 2.7 or newer");
+ "Recoverable writers on Hadoop are only supported for HDFS");
  }
 
  // Part of functionality depends on specific versions. We check these schemes and versions eagerly for