convert _ to / in table prefix

twitter-archive · Aug 6, 2010 · 85b0c29 · 85b0c29
1 parent 4d7e440
commit 85b0c29
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/scala/com/twitter/flockdb/jobs/Copy.scala b/src/main/scala/com/twitter/flockdb/jobs/Copy.scala
@@ -134,7 +134,7 @@ class MetadataCopy(sourceShardId: ShardId, destinationShardId: ShardId, cursor:
     }
     super.apply(environment)
   }
-g
+
   def copyPage(sourceShard: Shard, destinationShard: Shard, count: Int) = {
     if (destinationShard.needsMetadataCopyRestart()) {
       // If a flapp goes down mid copy, we get a copyPage call without corresponding startMetadataCopy

diff --git a/src/main/scala/com/twitter/flockdb/shards/HdfsBackupShard.scala b/src/main/scala/com/twitter/flockdb/shards/HdfsBackupShard.scala
@@ -72,7 +72,7 @@ class HdfsBackupShard(val shardInfo: ShardInfo, val weight: Int, val children: S
 
   val log = Logger.get(getClass.getName)
 
-  private val path = shardInfo.hostname + "/" + shardInfo.tablePrefix
+  private val path = shardInfo.hostname + "/" + shardInfo.tablePrefix.replace("_", "/")
   private val fs = FileSystem.get(URI.create(path), new Configuration)
   private val edgeThriftWritable = new ThriftB64LineWritable(new TypeRef[thrift.Edge] {})  
   private val metadataThriftWritable = new ThriftB64LineWritable(new TypeRef[thrift.Metadata] {})