fix

apache · Oct 24, 2024 · 5ad9ddf · 5ad9ddf
1 parent 96ac6db
commit 5ad9ddf
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java
@@ -111,6 +111,7 @@
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
+import java.util.zip.ZipEntry;
 import java.util.zip.ZipInputStream;
 import java.util.zip.ZipOutputStream;
 
@@ -2436,9 +2437,12 @@ public void write(DataOutput out) throws IOException {
 
             ByteArrayOutputStream bytesStream = new ByteArrayOutputStream();
             try (ZipOutputStream zipStream = new ZipOutputStream(bytesStream)) {
+                ZipEntry entry = new ZipEntry("restore_job");
+                zipStream.putNextEntry(entry);
                 try (DataOutputStream stream = new DataOutputStream(zipStream)) {
                     writeOthers(stream);
                 }
+                zipStream.closeEntry();
             }
             Text text = new Text(bytesStream.toByteArray());
             if (text.getLength() > (100 << 20)) {
@@ -2534,9 +2538,11 @@ public void readFields(DataInput in) throws IOException {
 
             ByteArrayInputStream bytesStream = new ByteArrayInputStream(text.getBytes());
             try (ZipInputStream zipStream = new ZipInputStream(bytesStream)) {
+                zipStream.getNextEntry();
                 try (DataInputStream stream = new DataInputStream(zipStream)) {
                     readOthers(stream);
                 }
+                zipStream.closeEntry();
             }
         } else {
             readOthers(in);