Alpakka cassandra throws exceptions with JDK 11 #2556

jeremycod · 2021-01-15T01:23:02Z

Versions used

Akka version:
2.6.10
akka-stream-alpakka-cassandra 2.0.2

java version:
openjdk version "11.0.9" 2020-10-20
OpenJDK Runtime Environment AdoptOpenJDK (build 11.0.9+11)
OpenJDK 64-Bit Server VM AdoptOpenJDK (build 11.0.9+11, mixed mode)

Expected Behavior

I'm trying to integrate alpakka-stream-cassandra into my project, but on project initialization getting a number of ClassNotFoundExceptions thrown from datastax driver. It looks to me as potential JDK 11 issue that might be harmless, but would like to be sure about it. Version compatiblity document https://developer.lightbend.com/docs/introduction/getting-help/java-versions.html is not very clear here. I'm not sure if alpakka-cassandra belongs to Alpakka in this compatibility matrix, or it's just missed from it.

Actual Behavior

First exception I'm getting is

15:22:07.360 [main] DEBUG com.datastax.oss.driver.internal.core.util.Reflection - Could not load com.esri.core.geometry.ogc.OGCGeometry: java.lang.ClassNotFoundException: com.esri.core.geometry.ogc.OGCGeometry
java.lang.ClassNotFoundException: com.esri.core.geometry.ogc.OGCGeometry
	at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:581)
	at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178)
	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:522)
	at java.base/java.lang.Class.forName0(Native Method)
	at java.base/java.lang.Class.forName(Class.java:315)
	at com.datastax.oss.driver.internal.core.util.Reflection.loadClass(Reflection.java:55)
	at com.datastax.oss.driver.internal.core.util.DependencyCheck.isPresent(DependencyCheck.java:68)
	at com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildCodecRegistry(DefaultDriverContext.java:570)
	at com.datastax.oss.driver.internal.core.context.DefaultDriverContext.<init>(DefaultDriverContext.java:255)
	at com.datastax.oss.driver.api.core.session.SessionBuilder.buildContext(SessionBuilder.java:721)
	at com.datastax.oss.driver.api.core.session.SessionBuilder.buildDefaultSessionAsync(SessionBuilder.java:666)
	at com.datastax.oss.driver.api.core.session.SessionBuilder.buildAsync(SessionBuilder.java:598)
	at akka.stream.alpakka.cassandra.DefaultSessionProvider.connect(CqlSessionProvider.scala:53)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSession.<init>(CassandraSession.scala:53)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.startSession(CassandraSessionRegistry.scala:99)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.$anonfun$sessionFor$1(CassandraSessionRegistry.scala:84)
	at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.sessionFor(CassandraSessionRegistry.scala:84)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.sessionFor(CassandraSessionRegistry.scala:74)
	at Main$.delayedEndpoint$Main$1(Main.scala:8)
	at Main$delayedInit$body.apply(Main.scala:4)
	at scala.Function0.apply$mcV$sp(Function0.scala:39)
	at scala.Function0.apply$mcV$sp$(Function0.scala:39)
	at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:17)
	at scala.App.$anonfun$main$1(App.scala:76)
	at scala.App.$anonfun$main$1$adapted(App.scala:76)
	at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:563)

If I add this dependency, I'm getting other netty related exceptions, e.g.:

15:50:29.620 [TransportServer-akka.actor.default-dispatcher-6] DEBUG io.netty.util.internal.PlatformDependent0 - direct buffer constructor: unavailable
java.lang.UnsupportedOperationException: Reflective setAccessible(true) disabled
	at io.netty.util.internal.ReflectionUtil.trySetAccessible(ReflectionUtil.java:31)
	at io.netty.util.internal.PlatformDependent0$4.run(PlatformDependent0.java:238)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at io.netty.util.internal.PlatformDependent0.<clinit>(PlatformDependent0.java:232)
	at io.netty.util.internal.PlatformDependent.isAndroid(PlatformDependent.java:289)
	at io.netty.util.internal.PlatformDependent.<clinit>(PlatformDependent.java:92)
	at io.netty.channel.nio.NioEventLoop.newTaskQueue0(NioEventLoop.java:279)
	at io.netty.channel.nio.NioEventLoop.newTaskQueue(NioEventLoop.java:150)
	at io.netty.channel.nio.NioEventLoop.<init>(NioEventLoop.java:138)
	at io.netty.channel.nio.NioEventLoopGroup.newChild(NioEventLoopGroup.java:146)
	at io.netty.channel.nio.NioEventLoopGroup.newChild(NioEventLoopGroup.java:37)
	at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84)
	at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58)
	at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47)
	at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59)
	at io.netty.channel.nio.NioEventLoopGroup.<init>(NioEventLoopGroup.java:86)
	at io.netty.channel.nio.NioEventLoopGroup.<init>(NioEventLoopGroup.java:81)
	at io.netty.channel.nio.NioEventLoopGroup.<init>(NioEventLoopGroup.java:68)
	at com.datastax.oss.driver.internal.core.context.DefaultNettyOptions.<init>(DefaultNettyOptions.java:84)
	at com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildNettyOptions(DefaultDriverContext.java:466)
	at com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get(LazyReference.java:55)
	at com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getNettyOptions(DefaultDriverContext.java:809)
	at com.datastax.oss.driver.internal.core.session.DefaultSession.<init>(DefaultSession.java:116)
	at com.datastax.oss.driver.internal.core.session.DefaultSession.init(DefaultSession.java:88)
	at com.datastax.oss.driver.api.core.session.SessionBuilder.buildDefaultSessionAsync(SessionBuilder.java:665)
	at com.datastax.oss.driver.api.core.session.SessionBuilder.buildAsync(SessionBuilder.java:598)
	at akka.stream.alpakka.cassandra.DefaultSessionProvider.connect(CqlSessionProvider.scala:53)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSession.<init>(CassandraSession.scala:53)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.startSession(CassandraSessionRegistry.scala:99)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.$anonfun$sessionFor$1(CassandraSessionRegistry.scala:84)
	at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.sessionFor(CassandraSessionRegistry.scala:84)
	at akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry.sessionFor(CassandraSessionRegistry.scala:74)
	at com.innovapost.transport.actor.TransportEventsConsumer$.$anonfun$apply$1(TransportEventsConsumer.scala:41)
	at akka.actor.typed.internal.BehaviorImpl$DeferredBehavior$$anon$1.apply(BehaviorImpl.scala:119)
	at akka.actor.typed.Behavior$.start(Behavior.scala:168)
	at akka.actor.typed.internal.adapter.ActorAdapter.preStart(ActorAdapter.scala:281)
	at akka.actor.Actor.aroundPreStart(Actor.scala:548)
	at akka.actor.Actor.aroundPreStart$(Actor.scala:548)
	at akka.actor.typed.internal.adapter.ActorAdapter.aroundPreStart(ActorAdapter.scala:256)
	at akka.actor.ActorCell.create(ActorCell.scala:641)
	at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:513)
	at akka.actor.ActorCell.systemInvoke(ActorCell.scala:535)
	at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:295)
	at akka.dispatch.Mailbox.run(Mailbox.scala:230)
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)

Reproducible Test Case

I've created minimal project that reproduces the problem and which is available here https://github.com/jeremycod/alpakka_stream_minimal

The text was updated successfully, but these errors were encountered:

ennru · 2021-01-20T11:18:26Z

Alpakka Cassandra excludes the "com.esri.geometry esri-geometry-api" library from its transitive dependencies. The security issues that made us take that route might be solved in later versions.

You can choose to add it in your project.

See #2225

jeremycod · 2021-01-20T16:34:43Z

Hi @ennru
Thanks for your response. I've already added that dependency, but I'm still having other exceptions. Please see second stack trace I've posted in original question. Shouldn't this be fixed with version 2.0.2?

ennru · 2021-01-21T09:07:33Z

Alpakka 2.0.2 uses the Cassandra Java Driver 4.6.1, you may try to use it with a later version.

I try version 4.10.0 in #2560

jeremycod · 2021-01-28T20:07:10Z

I've tried what you suggested, but without any luck. The problem still persist even with 4.10.0

sawanverma · 2021-10-18T13:22:57Z

I am getting the same exception as following
DEBUG io.netty.util.internal.PlatformDependent0 - direct buffer constructor: unavailable
java.lang.UnsupportedOperationException: Reflective setAccessible(true) disabled

Any solution as of now?

ennru · 2022-01-19T18:46:57Z

See #2804

ennru · 2022-02-04T15:57:48Z

#2804 upgraded the driver to version 4.13.

ennru added the p:cassandra label Jan 20, 2021

GeluOltean mentioned this issue Oct 23, 2021

Cassandra driver version bump 4.10 -> 4.11.0 #2762

Closed

ennru added this to the 4.0.0 milestone Jan 19, 2022

ennru closed this as completed Feb 4, 2022

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Alpakka cassandra throws exceptions with JDK 11 #2556

Alpakka cassandra throws exceptions with JDK 11 #2556

jeremycod commented Jan 15, 2021 •

edited

Loading

ennru commented Jan 20, 2021

jeremycod commented Jan 20, 2021

ennru commented Jan 21, 2021

jeremycod commented Jan 28, 2021

sawanverma commented Oct 18, 2021

ennru commented Jan 19, 2022

ennru commented Feb 4, 2022

Alpakka cassandra throws exceptions with JDK 11 #2556

Alpakka cassandra throws exceptions with JDK 11 #2556

Comments

jeremycod commented Jan 15, 2021 • edited Loading

Versions used

Expected Behavior

Actual Behavior

Reproducible Test Case

ennru commented Jan 20, 2021

jeremycod commented Jan 20, 2021

ennru commented Jan 21, 2021

jeremycod commented Jan 28, 2021

sawanverma commented Oct 18, 2021

ennru commented Jan 19, 2022

ennru commented Feb 4, 2022

jeremycod commented Jan 15, 2021 •

edited

Loading