[ACCUMULO-2051] Can't write to accumulo when using viewfs://

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.6.0
• Assignee: Keith Turner
• Reporter: Keith Turner
• Created: 18/Dec/13 04:11
• Updated: 20/Dec/13 04:15
• Resolved: 20/Dec/13 04:15

Description

See parent ticket for env info. Seeing the following error which prevents writing from the walog. Its easy to work around by changing the call from FileSystem.getDefaultReplication() to FileSystem.getDefaultReplication(Path path). However this easy work around will probably break Hadoop 1.0 support.

2013-12-18 04:03:25,120 [log.DfsLogger] DEBUG: DfsLogger.open() begin
2013-12-18 04:03:25,125 [log.TabletServerLogger] ERROR: Unexpected error writing to log, retrying attempt 1
java.lang.RuntimeException: java.io.IOException: org.apache.hadoop.fs.viewfs.NotInMountpointException: getDefaultReplication on empty path is invalid
        at org.apache.accumulo.tserver.log.TabletServerLogger.createLoggers(TabletServerLogger.java:191)
        at org.apache.accumulo.tserver.log.TabletServerLogger.access$300(TabletServerLogger.java:53)
        at org.apache.accumulo.tserver.log.TabletServerLogger$1.withWriteLock(TabletServerLogger.java:149)
        at org.apache.accumulo.tserver.log.TabletServerLogger.testLockAndRun(TabletServerLogger.java:116)
        at org.apache.accumulo.tserver.log.TabletServerLogger.initializeLoggers(TabletServerLogger.java:138)
        at org.apache.accumulo.tserver.log.TabletServerLogger.write(TabletServerLogger.java:246)
        at org.apache.accumulo.tserver.log.TabletServerLogger.logManyTablets(TabletServerLogger.java:364)
        at org.apache.accumulo.tserver.TabletServer$ThriftClientHandler.flush(TabletServer.java:1623)
        at org.apache.accumulo.tserver.TabletServer$ThriftClientHandler.closeUpdate(TabletServer.java:1710)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at org.apache.accumulo.trace.instrument.thrift.TraceWrap$1.invoke(TraceWrap.java:63)
        at com.sun.proxy.$Proxy15.closeUpdate(Unknown Source)
        at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Processor$closeUpdate.getResult(TabletClientService.java:2368)
        at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Processor$closeUpdate.getResult(TabletClientService.java:2352)
        at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
        at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
        at org.apache.accumulo.server.util.TServerUtils$TimedProcessor.process(TServerUtils.java:171)
        at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.invoke(AbstractNonblockingServer.java:478)
        at org.apache.accumulo.server.util.TServerUtils$THsHaServer$Invocation.run(TServerUtils.java:231)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at org.apache.accumulo.trace.instrument.TraceRunnable.run(TraceRunnable.java:47)
        at org.apache.accumulo.core.util.LoggingRunnable.run(LoggingRunnable.java:34)
        at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: org.apache.hadoop.fs.viewfs.NotInMountpointException: getDefaultReplication on empty path is invalid
        at org.apache.accumulo.tserver.log.DfsLogger.open(DfsLogger.java:400)
        at org.apache.accumulo.tserver.log.TabletServerLogger.createLoggers(TabletServerLogger.java:186)
        ... 26 more
Caused by: org.apache.hadoop.fs.viewfs.NotInMountpointException: getDefaultReplication on empty path is invalid
        at org.apache.hadoop.fs.viewfs.ViewFileSystem.getDefaultReplication(ViewFileSystem.java:492)
        at org.apache.accumulo.server.fs.VolumeManagerImpl.getDefaultReplication(VolumeManagerImpl.java:329)
        at org.apache.accumulo.tserver.log.DfsLogger.open(DfsLogger.java:333)
        ... 27 more