AHeise edited a comment on issue #11117: [FLINK-16115][filesystem] Make aliyun 
oss filesystem could work with plugin mechanism
URL: https://github.com/apache/flink/pull/11117#issuecomment-587528015
 
 
   @pnowojski , that's the thing, we wouldn't need to make any special changes 
to the plugins. Imho it was always broken.
   
   The issue is that `flink-hadoop-fs` is shaded into `flink-dist` (mostly 
because of MapR, but also for Kerberos).
   In flink-dist, ctor of `HadoopFileSystem` has this signature:
   `public HadoopFileSystem(org.apache.hadoop.fs.FileSystem hadoopFileSystem)`
   
   In relocated plugins, it is 
   ```
   public class org.apache.flink.runtime.fs.hdfs.HadoopFileSystem extends 
org.apache.flink.core.fs.FileSystem {
     public 
org.apache.flink.runtime.fs.hdfs.HadoopFileSystem(org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.FileSystem);
   ```
   
   The original [error](https://issues.apache.org/jira/browse/FLINK-16115) 
shows that the wrong HadoopFileSystem was loaded.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to