MapRFsFactory implements FileSystemFactory { @Override public FileSystem create(URI fsUri) throws IOException { checkNotNull(fsUri, "fsUri"); try { LOG.info("Trying to load and instantiate MapR File System"); return new MapRFileSystem(fsUri); } catch (LinkageError e) { throw new IOException("Could not load MapR file system. " + "Please make sure the Flink runtime classes are part of the classpath or dependencies.", e); } catch (IOException e) { throw e; } catch (Throwable t) { throw new IOException("Could not instantiate MapR file system.", t); } }  @Override String getScheme(); @Override void configure(Configuration config); @Override FileSystem create(URI fsUri);  }
@Test public void testCreateFsWithAuthority() throws Exception { final URI uri = URI.create("maprfs: MapRFsFactory factory = new MapRFsFactory(); try { factory.create(uri); fail("should have failed with an exception"); } catch (IOException e) { } }