Hi Abdul, "--classpath <url>" can be used for those are not included in user jar. If all your classes are included in your jar passed to Flink, you don't need this "--classpath".
Abdul Qadeer <quadeer....@gmail.com> 于2019年6月18日周二 上午3:08写道： > Hi! > > I was going through submission of a Flink program through CLI. I see that > "--classpath <url>" needs to be accessible from all nodes in the cluster as > per documentation. As I understand the jar files are already part of the > blob uploaded to JobManager from the CLI. The TaskManagers can download > this blob when the receive the task and access the classes from there. Why > is there a need to be able to access these files from every node then? It > makes sense to use Distributed File System to access these jars if the > network is not reachable to download blob files. Or if the blob doesn't > contain metadata to differentiate between child class loader classes and > the rest. However it seems like the TaskManager always tries to access the > specified class paths irrespective of Network Partitions. > >
