Commit f2342f59 by Sarath Subramanian

ATLAS-2349: Fix IT failures related to jackson serialization #2

parent 74e56544
...@@ -110,12 +110,12 @@ public class SqoopHookIT { ...@@ -110,12 +110,12 @@ public class SqoopHookIT {
waitFor(MAX_WAIT_TIME, new Predicate() { waitFor(MAX_WAIT_TIME, new Predicate() {
@Override @Override
public boolean evaluate() throws Exception { public boolean evaluate() throws Exception {
ArrayNode results = atlasClient.search(query, 10, 0); JsonNode results = atlasClient.search(query, 10, 0);
return results.size() > 0; return results.size() > 0;
} }
}); });
ArrayNode results = atlasClient.search(query, 10, 0); JsonNode results = atlasClient.search(query, 10, 0);
JsonNode row = results.get(0).get("t"); JsonNode row = results.get(0).get("t");
return row.get("id").asText(); return row.get("id").asText();
......
...@@ -89,8 +89,8 @@ public class StormAtlasHookIT { ...@@ -89,8 +89,8 @@ public class StormAtlasHookIT {
String query = String.format("from %s where name = \"%s\"", String query = String.format("from %s where name = \"%s\"",
StormDataTypes.STORM_TOPOLOGY.getName(), TOPOLOGY_NAME); StormDataTypes.STORM_TOPOLOGY.getName(), TOPOLOGY_NAME);
ArrayNode results = atlasClient.search(query, 10, 0); JsonNode results = atlasClient.search(query, 10, 0);
JsonNode row = results.get(0); JsonNode row = results.get(0);
return row.has("$id$") ? row.get("$id$").get("id").asText() : null; return row.has("$id$") ? row.get("$id$").get("id").asText() : null;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment