Hi, I am using this library -* jasync-postgresql* [1] for async calls to postgres in asyncio operator. I am using running Flink 1.9 on EMR. I am facing this error -
Caused by: java.lang.ClassCastException: io.netty.channel.epoll.EpollEventLoopGroup cannot be cast to io.netty.channel.MultithreadEventLoopGroup at com.github.jasync.sql.db.util.NettyUtils$DefaultEventLoopGroup$2.invoke(NettyUtils.kt:32) at com.github.jasync.sql.db.util.NettyUtils$DefaultEventLoopGroup$2.invoke(NettyUtils.kt:19) at kotlin.SynchronizedLazyImpl.getValue(LazyJVM.kt:74) at com.github.jasync.sql.db.util.NettyUtils.getDefaultEventLoopGroup(NettyUtils.kt) at com.github.jasync.sql.db.Configuration.<init>(Configuration.kt:55) at com.github.jasync.sql.db.Configuration.<init>(Configuration.kt) at com.flink.poc.inventory.AsyncJdbcRequest$AsyncDatabaseRequest.open(AsyncJdbcRequest.java:50) at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36) at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.open(AsyncWaitOperator.java:167) at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:529) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:393) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) at java.lang.Thread.run(Thread.java:748) I tried setting taskmanager.network.netty.transport: epoll still no difference. Is this because of the netty version used by flink and the library, this library uses - NETTY_VERSION=4.1.49.Final [1] - https://github.com/jasync-sql/jasync-sql Thanks, Hemant
