Skip to content

Commit fc29ef0

Browse files
Gargi JaiswalGargi Jaiswal
authored andcommitted
keep the current parseKVContainerData for most existing code cal
1 parent d30abbb commit fc29ef0

File tree

6 files changed

+19
-7
lines changed

6 files changed

+19
-7
lines changed

hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/keyvalue/helpers/KeyValueContainerUtil.java

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -196,9 +196,21 @@ public static boolean noBlocksInContainer(DatanodeStore store,
196196
* Parse KeyValueContainerData and verify checksum. Set block related
197197
* metadata like block commit sequence id, block count, bytes used and
198198
* pending delete block count and delete transaction id.
199+
* This method will verify checksum by default.
199200
* @param kvContainerData
200201
* @param config
201-
* @param skipVerifyChecksum
202+
* @throws IOException
203+
*/
204+
public static void parseKVContainerData(KeyValueContainerData kvContainerData,
205+
ConfigurationSource config) throws IOException {
206+
parseKVContainerData(kvContainerData, config, false);
207+
}
208+
209+
/**
210+
* @param kvContainerData
211+
* @param config
212+
* @param skipVerifyChecksum checksum verification should be skipped if the state
213+
* has changed to RECOVERING during container import, false otherwise
202214
* @throws IOException
203215
*/
204216
public static void parseKVContainerData(KeyValueContainerData kvContainerData,
@@ -207,7 +219,7 @@ public static void parseKVContainerData(KeyValueContainerData kvContainerData,
207219
long containerID = kvContainerData.getContainerID();
208220

209221
// Verify Checksum
210-
// skip verify checksum if the state has changed to RECOVERING
222+
// skip verify checksum if the state has changed to RECOVERING during container import
211223
if (!skipVerifyChecksum) {
212224
ContainerUtils.verifyChecksum(kvContainerData, config);
213225
}

hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,7 @@ public void verifyAndFixupContainerData(ContainerData containerData)
212212
KeyValueContainerData kvContainerData = (KeyValueContainerData)
213213
containerData;
214214
containerData.setVolume(hddsVolume);
215-
KeyValueContainerUtil.parseKVContainerData(kvContainerData, config, false);
215+
KeyValueContainerUtil.parseKVContainerData(kvContainerData, config);
216216
KeyValueContainer kvContainer = new KeyValueContainer(kvContainerData,
217217
config);
218218
if (kvContainer.getContainerState() == RECOVERING) {

hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/TestSchemaOneBackwardsCompatibility.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -610,7 +610,7 @@ private KeyValueContainerData newKvData() throws IOException {
610610
kvData.getReplicaIndex() > 0);
611611
kvData.computeAndSetChecksum(yaml);
612612

613-
KeyValueContainerUtil.parseKVContainerData(kvData, conf, false);
613+
KeyValueContainerUtil.parseKVContainerData(kvData, conf);
614614

615615
return kvData;
616616
}

hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ public void testMissingChunksDirCreated(ContainerTestVersionInfo versionInfo)
215215

216216
// When the container is loaded, the missing chunks directory should
217217
// be created.
218-
KeyValueContainerUtil.parseKVContainerData(data, CONF, false);
218+
KeyValueContainerUtil.parseKVContainerData(data, CONF);
219219
assertTrue(chunksDir.exists());
220220
}
221221

hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainerMetadataInspector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -505,7 +505,7 @@ private JsonNode runInspectorAndGetReport(
505505
GenericTestUtils.LogCapturer.captureLogs(
506506
toLog4j(KeyValueContainerMetadataInspector.REPORT_LOG),
507507
new PatternLayout());
508-
KeyValueContainerUtil.parseKVContainerData(containerData, getConf(), false);
508+
KeyValueContainerUtil.parseKVContainerData(containerData, getConf());
509509
capturer.stopCapturing();
510510
String output = capturer.getOutput();
511511
capturer.clearOutput();

hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/repair/datanode/schemaupgrade/UpgradeContainerSchema.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -372,7 +372,7 @@ private ContainerData parseContainerData(File containerDir) {
372372
KeyValueContainerData kvContainerData =
373373
(KeyValueContainerData) containerData;
374374
containerData.setVolume(hddsVolume);
375-
KeyValueContainerUtil.parseKVContainerData(kvContainerData, config, false);
375+
KeyValueContainerUtil.parseKVContainerData(kvContainerData, config);
376376
return kvContainerData;
377377
} else {
378378
error("Container is not KeyValueContainer type: %s.",

0 commit comments

Comments
 (0)