Hi, I found a ClassNotFound exception when using Flink 1.19's AsyncScalarFunction.
Stack trace: Caused by: java.lang.ClassNotFoundException: > org.apache.commons.text.StringSubstitutor > > at java.net.URLClassLoader.findClass(Unknown Source) ~[?:?] > > at java.lang.ClassLoader.loadClass(Unknown Source) ~[?:?] > > at > org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:150) > ~[flink-dist-1.19.0.jar:1.19.0] > > at > org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:113) > ~[flink-dist-1.19.0.jar:1.19.0] > > at java.lang.ClassLoader.loadClass(Unknown Source) ~[?:?] > > at > org.apache.flink.table.planner.codegen.AsyncCodeGenerator.generateProcessCode(AsyncCodeGenerator.java:173) > ~[?:?] > > at > org.apache.flink.table.planner.codegen.AsyncCodeGenerator.generateFunction(AsyncCodeGenerator.java:77) > ~[?:?] > > at > org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecAsyncCalc.getAsyncFunctionOperator(CommonExecAsyncCalc.java:146) > ~[?:?] > > at > org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecAsyncCalc.createAsyncOneInputTransformation(CommonExecAsyncCalc.java:126) > ~[?:?] > > at > org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecAsyncCalc.translateToPlanInternal(CommonExecAsyncCalc.java:89) > ~[?:?] > > 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.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94) > ~[?:?] > > 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) > ~[?:?] > Environment: flink image: flink:1.19.0-scala_2.12-java11 Tried solutions: I tried to package the needed dependency `commons-io-1.10.0.jar` into both user jar and the classpath and the issue remained. Would someone please help resolve this ?
