Can't load models in a Flink Cluster setup about flink-jpmml HOT 2 CLOSED

Dear Harish-Sridhar, thank you for your recent activity on this project.

Actually, flink-jpmml aims to serve models stored to the Flink underlying storage system. We've been made several tests with HDFS, Alluxio and even local FS. Even more, I'd suggest that TaskManager's do actually have the ability to access the FS directly w/o relying on the JobManager.

I guess your issue is that you're running in cluster-mode without relying on a distributed underlying FileSystem; this causes your TMs trying to access a local path which is not available in the machine (because is local in fact). Thus, I suggest you adopt a distributed filesystem approach if you run with a cluster.

Please, also note that you're using old APIs.
In later releases, flink-jpmml is now able to load dynamically PMML models by connecting an event stream with a control stream which provides the models' metadata. Take a look at the README.md file to grasp this concept better.

Hope it helps, I'm closing this issue because we can't identify any changes needed here.

from flink-jpmml.

Closing the issue because we can't identify any changes needed here.

from flink-jpmml.