title: Kafka connect to azure data lake connector task failed
body: <p>I'm using InstaClustr managed service where Kafka bootstrap server and Kafka connect reside. I have uploaded a connector I downloaded from:
  <a href="https://docs.axual.io/connector-catalog/current/adls-gen2-sink/index.html" rel="nofollow noreferrer">https://docs.axual.io/connector-catalog/current/adls-gen2-sink/index.html</a></p>
  <p>After I started the connector, I got an error message indicated below:
  <a href="https://i.stack.imgur.com/GZaJC.png" rel="nofollow noreferrer">enter image description here</a></p>
  <p>It says 'Null scanresults or scanresults types are not supported', however, I have no clue what does it entail, and I'm very new to Java.</p>
  <p>My configuration is like this:</p>
  <pre><code>**{
    &quot;name&quot;: &quot;my-connector&quot;,
    &quot;config&quot;: {
      &quot;connector.class&quot;: &quot;io.axual.connect.plugins.adls.gen2.AdlsGen2SinkConnector&quot;,
      &quot;tasks.max&quot;: &quot;3&quot;,
      &quot;topics&quot;: &quot;test&quot;,
      &quot;adls.endpoint&quot;: &quot;https://accountname.dfs.core.windows.net&quot;,
      &quot;adls.container.name&quot;: &quot;test&quot;,
      &quot;adls.auth.method&quot;: &quot;AccountKey&quot;,
      &quot;adls.account.name&quot;: &quot;myexampleadlsaccount&quot;,
      &quot;adls.account.key&quot;: &quot;get-this-from-the-azure-storage-account-settings&quot;,
      &quot;base.directory&quot;: &quot;base&quot;
    }
  }**
  </code></pre>
  <p>,</p>
  <p>The base directory was created in the azure data lake, however, after I put some messages through the console producer, nothing was generated in the data lake.</p>
  <p>The error message is shown here:</p>
  <pre><code>{&quot;state&quot;:&quot;FAILED&quot;,&quot;trace&quot;:&quot;org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
      at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:609)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:329)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
      at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
      at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:241)
      at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
      at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
      at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
      at java.base/java.lang.Thread.run(Thread.java:829)
  Caused by: io.axual.connect.plugins.adls.gen2.exceptions.AdlsGen2Exception: io.axual.connect.plugins.adls.gen2.exceptions.AdlsGen2Exception: Null scanresults or scanresult types are not supported
      at io.axual.connect.plugins.adls.gen2.AdlsGen2SinkTask.put(AdlsGen2SinkTask.java:157)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)
      ... 10 more
  Caused by: io.axual.connect.plugins.adls.gen2.exceptions.AdlsGen2Exception: Null scanresults or scanresult types are not supported
      at io.axual.connect.plugins.adls.gen2.avro.ContainerGenerator.determineInnerSchema(ContainerGenerator.java:118)
      at io.axual.connect.plugins.adls.gen2.avro.ContainerGenerator.createKafkaKeyValueContainer(ContainerGenerator.java:105)
      at io.axual.connect.plugins.adls.gen2.avro.ContainerGenerator.createContainer(ContainerGenerator.java:97)
      at io.axual.connect.plugins.adls.gen2.avro.AvroADLSFile.processRecords(AvroADLSFile.java:193)
      at io.axual.connect.plugins.adls.gen2.AdlsGen2SinkTask.lambda$put$4(AdlsGen2SinkTask.java:142)
      at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
      at java.base/java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764)
      at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
      at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
      at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
      at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
      at java.base/java.util.stream.ReferencePipeline.reduce(ReferencePipeline.java:558)
      at io.axual.connect.plugins.adls.gen2.AdlsGen2SinkTask.put(AdlsGen2SinkTask.java:143)\
      ... 11 more\&quot;,&quot;worker_id&quot;:&quot;10.201.0.1:8083&quot;,&quot;generation&quot;:85}
  </code></pre>