src/main/java/org/embulk/input/zendesk/ZendeskInputPlugin.java in embulk-input-zendesk-0.3.6 vs src/main/java/org/embulk/input/zendesk/ZendeskInputPlugin.java in embulk-input-zendesk-0.3.7
- old
+ new
@@ -284,10 +284,10 @@
final JsonNode sample = new ObjectMapper().valueToTree(StreamSupport.stream(
jsonNode.get(target.getJsonName()).spliterator(), false).limit(10).collect(Collectors.toList()));
final Buffer bufferSample = Buffer.copyOf(sample.toString().getBytes(StandardCharsets.UTF_8));
final JsonNode columns = Exec.getInjector().getInstance(GuessExecutor.class)
.guessParserConfig(bufferSample, Exec.newConfigSource(), createGuessConfig())
- .getObjectNode().get("columns");
+ .get(JsonNode.class, "columns");
final Iterator<JsonNode> ite = columns.elements();
while (ite.hasNext()) {
final ObjectNode entry = (ObjectNode) ite.next();