storage: Fix stderr sorting. #TASK-6722

opencb · Oct 25, 2024 · 356567e · 356567e
1 parent 697b08b
commit 356567e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...-core/src/main/java/org/opencb/opencga/storage/hadoop/variant/mr/StreamVariantMapper.java b/...-core/src/main/java/org/opencb/opencga/storage/hadoop/variant/mr/StreamVariantMapper.java
@@ -465,7 +465,7 @@ public void run() {
         private void write(Text line) throws IOException, InterruptedException {
             numRecords++;
             context.write(new ImmutableBytesWritable(
-                    Bytes.toBytes(StreamVariantReducer.STDOUT_KEY + outputKeyPrefix + (stdoutKeyNum++))), line);
+                    Bytes.toBytes(String.format("%s%s%08d", StreamVariantReducer.STDOUT_KEY, outputKeyPrefix, stdoutKeyNum++))), line);
         }
     }
 
@@ -546,7 +546,7 @@ private void write(String line) throws IOException, InterruptedException {
 
         private void write(Text line) throws IOException, InterruptedException {
             context.write(new ImmutableBytesWritable(
-                    Bytes.toBytes(StreamVariantReducer.STDERR_KEY + outputKeyPrefix + (stderrKeyNum++))), line);
+                    Bytes.toBytes(String.format("%s%s%08d", StreamVariantReducer.STDERR_KEY, outputKeyPrefix, stderrKeyNum++))), line);
         }
 
         private boolean matchesReporter(String line) {