java.lang.IllegalAccessError

[m-prajapati]

Hi,
I'm facing below error while running connector. Any quick guide in this ?

java.lang.IllegalAccessError: tried to access field io.confluent.connect.hdfs.HdfsSinkConnectorConfig.config from class com.qubole.streamx.s3.S3SinkConnectorConfig

-- error log
java.lang.IllegalAccessError: tried to access field io.confluent.connect.hdfs.HdfsSinkConnectorConfig.config from class com.qubole.streamx.s3.S3SinkConnectorConfig
at com.qubole.streamx.s3.S3SinkConnectorConfig.(S3SinkConnectorConfig.java:64)
at com.qubole.streamx.s3.S3SinkConnector.start(S3SinkConnector.java:51)
at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:101)
at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:126)
at org.apache.kafka.connect.runtime.WorkerConnector.transitionTo(WorkerConnector.java:183)
at org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:178)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startConnector(DistributedHerder.java:789)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startWork(DistributedHerder.java:755)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.handleRebalanceCompleted(DistributedHerder.java:715)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:206)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:176)

at java.lang.Thread.run(Thread.java:745)

Thanks,
Mayank

[PraveenSeluka]

Do you have kafka-connect-hdfs in the classpath ? That might cause issues. Also, it works with confluent 3.0.0 version - this sounds like you have older version of it. Can you check and respond.

Thanks

[m-prajapati]

Thanks Praveen for quick reply.

Yes, I'm running on confluent 3.0.0 version. I'm not getting on kafka-connect-hdfs part, As per my understanding all required classes related kafka-connect-hdfs are in package of streamx (io.confluent.connect.hdfs).

Do I need to add any specific library that not part of it ? can you point me on this.

Mayank

[PraveenSeluka]

Am not sure how confluent packages it. Mostly the classpath already contains kafka-connect-hdfs - and thats causing this issue. You might need to remove kafka-connect-hdfs from classpath. (StreamX is forked from kafka-connect-hdfs and it has some changes)

[m-prajapati]

Thanks Praveen.

Finally able to make it work. one quick question, does connector support JSON format ?

[PraveenSeluka]

We are currently working on adding JSON support. It will be available soon.

On Tue, Aug 30, 2016 at 8:34 PM m-prajapati notifications@github.com
wrote:

Thanks Praveen.

Finally able to make it work. one quick question, does connector support
JSON format ?

—
You are receiving this because you commented.

Reply to this email directly, view it on GitHub
#13 (comment), or mute
the thread
https://github.com/notifications/unsubscribe-auth/AFF4Poz-eIhiiyhlGuOYubVMzIX5-Na1ks5qlEZ1gaJpZM4JrY82
.

[m-prajapati]

Thanks Praveen.

[PraveenSeluka]

Am closing this issue. Regarding JSON support, please see the getting started section. You can use ByteArrayConverter and SourceFormat to copy JSON data as-is. Thanks