SteveStevenpoor opened a new issue, #11790:
URL: https://github.com/apache/gluten/issues/11790
### Backend
VL (Velox)
### Bug description
When trying to run nexmark q3 with flink-19.2 + gluten + velox4j I
encountered submission error. Note that Q0-Q2 works (but pretty slow).
Nexmark run_query.sh output:
```bash
Nexmark output: Benchmark Queries: [q3]
==================================================================
Start to run query q3 with workload [tps=10 M, eventsNum=100 M,
percentage=bid:46,auction:3,person:1,kafkaServers:null]
Exception in thread "main" java.lang.RuntimeException: Cannot find Job ID
from the sql client output, maybe the job is not successfully submitted.
at
com.github.nexmark.flink.QueryRunner.submitSQLJob(QueryRunner.java:209)
at
com.github.nexmark.flink.QueryRunner.runInternal(QueryRunner.java:143)
at com.github.nexmark.flink.QueryRunner.run(QueryRunner.java:87)
at com.github.nexmark.flink.Benchmark.executeQueries(Benchmark.java:226)
at com.github.nexmark.flink.Benchmark.runQueries(Benchmark.java:128)
at com.github.nexmark.flink.Benchmark.main(Benchmark.java:83)
```
SQL client log:
```bash
2026-03-19 14:11:34,992 WARN org.apache.gluten.velox.VeloxSourceSinkFactory
[] - Not find matched factory to build velox source
transformation, and we will use flink original transformation
org.apache.flink.streaming.api.transformations.SourceTransformation instead.
2026-03-19 14:11:35,218 ERROR
org.apache.flink.table.gateway.service.operation.OperationManager [] - Failed
to execute the operation 8469e956-6bcf-4ff6-ba1f-03fb41d76c02.
java.lang.UnsatisfiedLinkError: 'java.lang.String
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(java.lang.String)'
at
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(Native
Method) ~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
io.github.zhztheplayer.velox4j.jni.StaticJniApi.variantInferType(StaticJniApi.java:104)
~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
io.github.zhztheplayer.velox4j.expression.ConstantTypedExpr.create(ConstantTypedExpr.java:63)
~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:147)
~[?:?]
at
org.apache.gluten.rexnode.functions.SearchRexCallConverter.toTypedExpr(SearchRexCallConverter.java:64)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.lambda$toTypedExpr$0(RexNodeConverter.java:89)
~[?:?]
at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
at
java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
~[?:?]
at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
~[?:?]
at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
~[?:?]
at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:90)
~[?:?]
at
org.apache.gluten.rexnode.functions.BaseRexCallConverter.getParams(BaseRexCallConverters.java:43)
~[?:?]
at
org.apache.gluten.rexnode.functions.DefaultRexCallConverter.toTypedExpr(BaseRexCallConverters.java:73)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:135)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecExchange.translateToPlanInternal(StreamExecExchange.java:120)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecJoin.translateToPlanInternal(StreamExecJoin.java:181)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:121)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.java:177)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.delegation.StreamPlanner.$anonfun$translateToPlan$1(StreamPlanner.scala:85)
~[?:?]
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.Iterator.foreach(Iterator.scala:937)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.Iterator.foreach$(Iterator.scala:937)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at
org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:84)
~[?:?]
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:180)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1296)
~[flink-table-api-java-uber-1.19.2.jar:1.19.2]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:874)
~[flink-table-api-java-uber-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callModifyOperations(OperationExecutor.java:586)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:462)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
2026-03-19 14:11:35,288 ERROR
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl [] - Failed to
fetchResults.
org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed
to execute the operation 8469e956-6bcf-4ff6-ba1f-03fb41d76c02.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
~[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: java.lang.UnsatisfiedLinkError: 'java.lang.String
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(java.lang.String)'
at
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(Native
Method) ~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
io.github.zhztheplayer.velox4j.jni.StaticJniApi.variantInferType(StaticJniApi.java:104)
~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
io.github.zhztheplayer.velox4j.expression.ConstantTypedExpr.create(ConstantTypedExpr.java:63)
~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:147)
~[?:?]
at
org.apache.gluten.rexnode.functions.SearchRexCallConverter.toTypedExpr(SearchRexCallConverter.java:64)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.lambda$toTypedExpr$0(RexNodeConverter.java:89)
~[?:?]
at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
at
java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
~[?:?]
at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
~[?:?]
at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
~[?:?]
at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:90)
~[?:?]
at
org.apache.gluten.rexnode.functions.BaseRexCallConverter.getParams(BaseRexCallConverters.java:43)
~[?:?]
at
org.apache.gluten.rexnode.functions.DefaultRexCallConverter.toTypedExpr(BaseRexCallConverters.java:73)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:135)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecExchange.translateToPlanInternal(StreamExecExchange.java:120)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecJoin.translateToPlanInternal(StreamExecJoin.java:181)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:121)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.java:177)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.delegation.StreamPlanner.$anonfun$translateToPlan$1(StreamPlanner.scala:85)
~[?:?]
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.Iterator.foreach(Iterator.scala:937)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.Iterator.foreach$(Iterator.scala:937)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at
org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:84)
~[?:?]
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:180)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1296)
~[flink-table-api-java-uber-1.19.2.jar:1.19.2]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:874)
~[flink-table-api-java-uber-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callModifyOperations(OperationExecutor.java:586)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:462)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
... 7 more
2026-03-19 14:11:35,295 ERROR
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler [] -
Unhandled exception.
org.apache.flink.table.gateway.api.utils.SqlGatewayException:
org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to
fetchResults.
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:91)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:84)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:52)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:196)
~[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:88)
~[flink-dist-1.19.2.jar:1.19.2]
at java.util.Optional.ifPresent(Optional.java:183) [?:?]
at
org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:85)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:50)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:233)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:70)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[flink-dist-1.19.2.jar:1.19.2]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException:
Failed to fetchResults.
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:89)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
... 48 more
Caused by:
org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed to
execute the operation 8469e956-6bcf-4ff6-ba1f-03fb41d76c02.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
~[?:?]
... 1 more
Caused by: java.lang.UnsatisfiedLinkError: 'java.lang.String
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(java.lang.String)'
at
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(Native
Method) ~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
io.github.zhztheplayer.velox4j.jni.StaticJniApi.variantInferType(StaticJniApi.java:104)
~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
io.github.zhztheplayer.velox4j.expression.ConstantTypedExpr.create(ConstantTypedExpr.java:63)
~[velox4j-0.1.0-SNAPSHOT.jar:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:147)
~[?:?]
at
org.apache.gluten.rexnode.functions.SearchRexCallConverter.toTypedExpr(SearchRexCallConverter.java:64)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.lambda$toTypedExpr$0(RexNodeConverter.java:89)
~[?:?]
at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
at
java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
~[?:?]
at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
~[?:?]
at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
~[?:?]
at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:90)
~[?:?]
at
org.apache.gluten.rexnode.functions.BaseRexCallConverter.getParams(BaseRexCallConverters.java:43)
~[?:?]
at
org.apache.gluten.rexnode.functions.DefaultRexCallConverter.toTypedExpr(BaseRexCallConverters.java:73)
~[?:?]
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:135)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecExchange.translateToPlanInternal(StreamExecExchange.java:120)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecJoin.translateToPlanInternal(StreamExecJoin.java:181)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:121)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.java:177)
~[?:?]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
~[?:?]
at
org.apache.flink.table.planner.delegation.StreamPlanner.$anonfun$translateToPlan$1(StreamPlanner.scala:85)
~[?:?]
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.Iterator.foreach(Iterator.scala:937)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.Iterator.foreach$(Iterator.scala:937)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
~[flink-scala_2.12-1.19.2.jar:1.19.2]
at
org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:84)
~[?:?]
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:180)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1296)
~[flink-table-api-java-uber-1.19.2.jar:1.19.2]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:874)
~[flink-table-api-java-uber-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callModifyOperations(OperationExecutor.java:586)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:462)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.2.jar:1.19.2]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
~[?:?]
... 1 more
2026-03-19 14:11:35,308 WARN org.apache.flink.table.client.cli.CliClient
[] - Could not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Failed to get
response for the operation 8469e956-6bcf-4ff6-ba1f-03fb41d76c02.
at
org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:489)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.gateway.ExecutorImpl.fetchUtilResultsReady(ExecutorImpl.java:449)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.gateway.ExecutorImpl.executeStatement(ExecutorImpl.java:310)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.cli.parser.SqlMultiLineParser.parse(SqlMultiLineParser.java:114)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.jline.reader.impl.LineReaderImpl.acceptLine(LineReaderImpl.java:2964)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.jline.reader.impl.LineReaderImpl$1.apply(LineReaderImpl.java:3778)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.jline.reader.impl.LineReaderImpl.readLine(LineReaderImpl.java:679)
~[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.cli.CliClient.getAndExecuteStatements(CliClient.java:194)
[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:179)
[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:121)
[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:114)
[flink-sql-client-1.19.2.jar:1.19.2]
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:169)
[flink-sql-client-1.19.2.jar:1.19.2]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:118)
[flink-sql-client-1.19.2.jar:1.19.2]
at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:228)
[flink-sql-client-1.19.2.jar:1.19.2]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:179)
[flink-sql-client-1.19.2.jar:1.19.2]
Caused by: org.apache.flink.runtime.rest.util.RestClientException: [Internal
server error., <Exception on server side:
org.apache.flink.table.gateway.api.utils.SqlGatewayException:
org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to
fetchResults.
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:91)
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:84)
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:52)
at
org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:196)
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:88)
at java.base/java.util.Optional.ifPresent(Optional.java:183)
at
org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:85)
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:50)
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:233)
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:70)
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at
org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException:
Failed to fetchResults.
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229)
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:89)
... 48 more
Caused by:
org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed to
execute the operation 8469e956-6bcf-4ff6-ba1f-03fb41d76c02.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
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.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)
... 1 more
Caused by: java.lang.UnsatisfiedLinkError: 'java.lang.String
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(java.lang.String)'
at
io.github.zhztheplayer.velox4j.jni.StaticJniWrapper.variantInferType(Native
Method)
at
io.github.zhztheplayer.velox4j.jni.StaticJniApi.variantInferType(StaticJniApi.java:104)
at
io.github.zhztheplayer.velox4j.expression.ConstantTypedExpr.create(ConstantTypedExpr.java:63)
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:147)
at
org.apache.gluten.rexnode.functions.SearchRexCallConverter.toTypedExpr(SearchRexCallConverter.java:64)
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
at
org.apache.gluten.rexnode.RexNodeConverter.lambda$toTypedExpr$0(RexNodeConverter.java:89)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
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.collect(ReferencePipeline.java:578)
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:90)
at
org.apache.gluten.rexnode.functions.BaseRexCallConverter.getParams(BaseRexCallConverters.java:43)
at
org.apache.gluten.rexnode.functions.DefaultRexCallConverter.toTypedExpr(BaseRexCallConverters.java:73)
at
org.apache.gluten.rexnode.RexNodeConverter.toTypedExpr(RexNodeConverter.java:69)
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:135)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecExchange.translateToPlanInternal(StreamExecExchange.java:120)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecJoin.translateToPlanInternal(StreamExecJoin.java:181)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.java:121)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:259)
at
org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.java:177)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
at
org.apache.flink.table.planner.delegation.StreamPlanner.$anonfun$translateToPlan$1(StreamPlanner.scala:85)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:84)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:180)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1296)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:874)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callModifyOperations(OperationExecutor.java:586)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:462)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
... 7 more
End of exception on server side>]
at
org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:644)
~[flink-dist-1.19.2.jar:1.19.2]
at
org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:628)
~[flink-dist-1.19.2.jar:1.19.2]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
~[?:?]
at
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
~[?:?]
at java.lang.Thread.run(Thread.java:829) ~[?:?]
```
### Gluten version
_No response_
### Spark version
None
### Spark configurations
_No response_
### System information
_No response_
### Relevant logs
```bash
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
