I think that is a very good idea. Originally, we wrapped the Hadoop FS classes for convenience (they were changing, we wanted to keep the system independent of Hadoop), but these are no longer relevant reasons, in my opinion.
Let's start with your proposal and see if we can actually get rid of the wrapping in a way that is friendly to existing users. Would you open an issue for this? Greetings, Stephan On Wed, Aug 26, 2015 at 6:23 PM, LINZ, Arnaud <al...@bouyguestelecom.fr> wrote: > Hi, > > > > I’ve noticed that when you use org.apache.flink.core.fs.FileSystem to > write into a hdfs file, calling > org.apache.flink.runtime.fs.hdfs.HadoopFileSystem.create(), it returns a > HadoopDataOutputStream that wraps a > org.apache.hadoop.fs.FSDataOutputStream (under its > org.apache.hadoop.hdfs.client .HdfsDataOutputStream wrappper). > > > > However, FSDataOutputStream exposes many methods like flush, getPos etc, > but HadoopDataOutputStream only wraps write & close. > > > > For instance, flush() calls the default, empty implementation of > OutputStream instead of the hadoop one, and that’s confusing. Moreover, > because of the restrictive OutputStream interface, hsync() and hflush() are > not exposed to Flink ; maybe having a getWrappedStream() would be > convenient. > > > > (For now, that prevents me from using Flink FileSystem object, I directly > use hadoop’s one). > > > > Regards, > > Arnaud > > > > > > > > > > ------------------------------ > > L'intégrité de ce message n'étant pas assurée sur internet, la société > expéditrice ne peut être tenue responsable de son contenu ni de ses pièces > jointes. Toute utilisation ou diffusion non autorisée est interdite. Si > vous n'êtes pas destinataire de ce message, merci de le détruire et > d'avertir l'expéditeur. > > The integrity of this message cannot be guaranteed on the Internet. The > company that sent this message cannot therefore be held liable for its > content nor attachments. Any unauthorized use or dissemination is > prohibited. If you are not the intended recipient of this message, then > please delete it and notify the sender. >
