Re: modify the classloader of JM dynamically to handle "ADD JAR hdfs://" statement

Hi vtygoss, Have you taken a look at Zeppelin ? Zeppelin support Flink UDF in several different approaches, and as you said, it is not a good practice to put udf jars under $FLINK_HOME/lib. In Zeppelin you don't do that, you can dynamically load udf jars. Check the following doc for more details.

modify the classloader of JM dynamically to handle "ADD JAR hdfs://" statement

Hi, community! I am working on building a stream processing platform using Flink 1.12.0. I met a problem in the scenario of SQL Application migration from SparkSQL/HiveSQL to FlinkSQL. How to dynamically modify the classloader of the JobManager already launched to handle "ADD JAR HDFS://...