-
Notifications
You must be signed in to change notification settings - Fork 339
Open
Description
Attempting to use the S3 Source connector I get this exception which appears to be an issue parsing the KCQL in the configuration. For reference the KCQL being presented is:
connect.s3.kcql=insert into test_topic select * from test_bucket:prefix STOREASJSON
I am using image 3.9.0-L0
A quick google suggests there is a stale dependency somewhere but I not familiar enough with this to know how to fix it.
(io.lenses.streamreactor.connect.aws.s3.source.config.S3SourceConfigDefBuilder:371)
java.lang.NoClassDefFoundError: Could not initialize class io.lenses.kcql.antlr4.ConnectorLexer
at io.lenses.kcql.Kcql.parse(Kcql.java:261)
at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)
at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
at io.lenses.kcql.Kcql.parseMultiple(Kcql.java:256)
at io.lenses.streamreactor.common.config.base.traits.KcqlSettings.getKCQL(KcqlSettings.scala:28)
at io.lenses.streamreactor.common.config.base.traits.KcqlSettings.getKCQL$(KcqlSettings.scala:27)
at io.lenses.streamreactor.connect.cloud.common.source.config.CloudSourceConfigDefBuilder.getKCQL(CloudSourceConfigDefBuilder.scala:25)
at io.lenses.streamreactor.connect.cloud.common.source.config.CloudSourceBucketOptions$.apply(CloudSourceBucketOptions.scala:41)
at io.lenses.streamreactor.connect.aws.s3.source.config.S3SourceConfig$.apply(S3SourceConfig.scala:47)
at io.lenses.streamreactor.connect.aws.s3.source.config.S3SourceConfig$.fromProps(S3SourceConfig.scala:42)
at io.lenses.streamreactor.connect.aws.s3.source.S3SourceTask.convertPropsToConfig(S3SourceTask.scala:58)
at io.lenses.streamreactor.connect.cloud.common.source.CloudSourceTask.$anonfun$make$1(CloudSourceTask.scala:132)
at cats.effect.IOFiber.next$2(IOFiber.scala:397)
at cats.effect.IOFiber.runLoop(IOFiber.scala:408)
at cats.effect.IOFiber.execR(IOFiber.scala:1397)
at cats.effect.IOFiber.run(IOFiber.scala:122)
at cats.effect.unsafe.WorkerThread.lookForWork$1(WorkerThread.scala:515)
at cats.effect.unsafe.WorkerThread.run(WorkerThread.scala:858)
Caused by: java.lang.ExceptionInInitializerError: Exception java.lang.UnsupportedOperationException: java.io.InvalidClassException: org.antlr.v4.runtime.atn.ATN; Could not deserialize ATN with version 3 (expected 4).
Further up there is a the warning
ANTLR Tool version 4.7.1 used for code generation does not match the current runtime version 4.13.1
ANTLR Runtime version 4.7.1 used for parser compilation does not match the current runtime version 4.13.1
Metadata
Metadata
Assignees
Labels
No labels