From 9cc4eb2cd358a71b50ec201d948c4fee03aff1e7 Mon Sep 17 00:00:00 2001 From: hexiang55 Date: Thu, 1 Jun 2017 15:55:59 +0800 Subject: [PATCH] hdfs rename bug @Deprecated protected void rename(Path src, Path dst, Rename... options) must change to rename(Path var1, Path var2) Exception in thread "plumber_merge_0" java.lang.IllegalAccessError: tried to access method org.apache.hadoop.fs.FileSystem.rename(Lorg/apache/hadoop/fs/Path;Lorg/apache/hadoop/fs/Path;[Lorg/apache/hadoop/fs/Options$Rename;)V from class org.apache.hadoop.fs.HadoopFsWrapper at org.apache.hadoop.fs.HadoopFsWrapper.rename(HadoopFsWrapper.java:51) at io.druid.storage.hdfs.HdfsDataSegmentPusher.copyFilesWithChecks(HdfsDataSegmentPusher.java:161) at io.druid.storage.hdfs.HdfsDataSegmentPusher.push(HdfsDataSegmentPusher.java:142) at io.druid.segment.realtime.plumber.RealtimePlumber$2.doRun(RealtimePlumber.java:430) at io.druid.common.guava.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:42) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) --- .../main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java b/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java index 6b80e3619c25..d093a738b591 100644 --- a/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java +++ b/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java @@ -158,7 +158,7 @@ public DataSegment push(File inDir, DataSegment segment) throws IOException private void copyFilesWithChecks(final FileSystem fs, final Path from, final Path to) throws IOException { - if (!HadoopFsWrapper.rename(fs, from, to)) { + if (!fs.rename(from, to)) { if (fs.exists(to)) { log.info( "Unable to rename temp Index file[%s] to final segment path [%s]. "