From 726f0e19811484d8cbf883bc2f4a492002091600 Mon Sep 17 00:00:00 2001
From: tanyuxin <tanyuxin@meituan.com>
Date: Fri, 15 Feb 2019 14:50:44 +0800
Subject: [PATCH] Fix State transition err when hdfs ccm feature is used

---
 .../linkedin/dynamometer/blockgenerator/XMLParser.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/dynamometer-blockgen/src/main/java/com/linkedin/dynamometer/blockgenerator/XMLParser.java b/dynamometer-blockgen/src/main/java/com/linkedin/dynamometer/blockgenerator/XMLParser.java
index 3b915c23b2..afecbbd398 100644
--- a/dynamometer-blockgen/src/main/java/com/linkedin/dynamometer/blockgenerator/XMLParser.java
+++ b/dynamometer-blockgen/src/main/java/com/linkedin/dynamometer/blockgenerator/XMLParser.java
@@ -52,6 +52,16 @@ class XMLParser {
    * @return {@code BlockInfo}s for any blocks found.
    */
   List<BlockInfo> parseLine(String line) throws IOException {
+    // Centralized Cache Management compatibility
+    // if CCM feature is open, fsimage xml may include
+    // <directive><id>8963</id><path>/user/some/path</path><replication>3</replication>
+    // <pool>cache_other_pool</pool><expiration><millis>1544454142310</millis><relatilve>false</relatilve></expiration>
+    // these lines need to be filtered
+    if (line.contains("<directive><id>")) {
+      System.out.println("this line is for Centralized Cache Management, ignore, line:" + line);
+      return new ArrayList<>();
+    }
+
     if (line.contains("<inode>")) {
       transitionTo(State.INODE);
     }