AW: Flink UDF registration from jar at runtime

Hi Guowei, 1. Unfortunately the UDF and the job are not in the same fatjar. Essentially there is only one "fatjar" containing the Flink environment + the job, the UDF is separate. 2. Yes, that is correct. 3. As explained in 1. I don't submit job jars to the Flink environment, instea

AW: Flink UDF registration from jar at runtime

Hi Guowei, Thanks for your help, here is the relevant code (QueryCommand class): val fsSettings: EnvironmentSettings = EnvironmentSettings .newInstance() .useBlinkPlanner() .inStreamingMode() .build() val fsEnv: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnviro