Merge pull request #23 from 4paradigm/bugfix/del-pmem-channel

zhanghaohit · web-flow · commit c5e62b66c0e7 · 2021-10-11T14:07:32.000+08:00
fix: not delete id file after migration crash
diff --git a/clients/src/main/java/org/apache/kafka/common/record/pmem/MixChannel.java b/clients/src/main/java/org/apache/kafka/common/record/pmem/MixChannel.java
@@ -240,7 +240,7 @@ public MixChannel(Path file, int initFileSize, boolean preallocate, boolean muta
                     if (PMemChannel.exists(file)) {
                         log.error(file + " exist, but no info from metaStore.");
                         PMemChannel ch = (PMemChannel) PMemChannel.open(file, initFileSize, preallocate, mutable);
-                        ch.delete();
+                        ch.delete(false);
                     }
                     break;
                 default:

Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,7 @@ public MixChannel(Path file, int initFileSize, boolean preallocate, boolean muta`
`240`	`240`	`if (PMemChannel.exists(file)) {`
`241`	`241`	`log.error(file + " exist, but no info from metaStore.");`
`242`	`242`	`PMemChannel ch = (PMemChannel) PMemChannel.open(file, initFileSize, preallocate, mutable);`
`243`		`- ch.delete();`
	`243`	`+ ch.delete(false);`
`244`	`244`	`}`
`245`	`245`	`break;`
`246`	`246`	`default:`