Gobblin: csv to avro ОШИБКА: java.lang.IllegalStateException: это не массив JSON

Question

Я пытаюсь загрузить файлы csv из локальной системы в hdfs в формате avro. Я начал с помощью gobblin-example/resources/main/csvToAvro.conf. что дает мне ошибку ниже.

IST ERROR [TaskExecutor-1] org.apache.gobblin.runtime.Task  567 - Task task_lense_1583480739167_3 failed
java.lang.IllegalStateException: This is not a JSON Array.
    at com.google.gson.JsonElement.getAsJsonArray(JsonElement.java:106)
    at org.apache.gobblin.converter.csv.CsvToJsonConverter.convertSchema(CsvToJsonConverter.java:51)
    at org.apache.gobblin.converter.csv.CsvToJsonConverter.convertSchema(CsvToJsonConverter.java:40)
    at org.apache.gobblin.instrumented.converter.InstrumentedConverterDecorator.convertSchema(InstrumentedConverterDecorator.java:79)
    at org.apache.gobblin.runtime.MultiConverter.convertSchema(MultiConverter.java:76)
    at org.apache.gobblin.runtime.Task.runSynchronousModel(Task.java:427)
    at org.apache.gobblin.runtime.Task.run(Task.java:362)
    at org.apache.gobblin.runtime.TaskExecutor$TrackingTask.run(TaskExecutor.java:443)
    at org.apache.gobblin.util.executors.MDCPropagatingRunnable.run(MDCPropagatingRunnable.java:39)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

классы преобразователя указаны ниже.

converter.classes=org.apache.gobblin.converter.StringSchemaInjector,org.apache.gobblin.converter.csv.CsvToJsonConverter,org.apache.gobblin.converter.avro.JsonIntermediateToAvroConverter
writer.builder.class=org.apache.gobblin.writer.AvroDataWriterBuilder

Как я могу это решить? пожалуйста помоги.