I think you could use Flink distributed cache to make the files available
on all
TaskManagers. For example,
*env.registerCachedFile(cacheFilePath, "cacheFile", false);*
and then, using the following code to get the registered file in the
operator.
*getRuntimeContext().getDistributedCache().getF
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 t
