I want to make UDTF into a jar package??Then load the jar in the Main method of Job through dynamic loading and get the UDTF class. But in this way,flink does not automatically distribute Jar to tashManager??So it caused an error??
I find that FlinkClient provides the -C Bringing -C with the function jar URL when running the job can achieve the effect I want. But I don't want to directly operate the Flink client On the other hand,The Apache Flink Dashboard did not provide the corresponding input parameters.and the REST API did not find the one that meets the requirements,too. Is there any good suggestion to distribute the function jar I submitted to all taskManager? thanks.
