Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5580 @aljoscha Yes that's right. The latest commit does not work because Python API expects complete directories to be uploaded. I think it is quite important cause this way the uploaded Python code can be modularized and python libs can be used. Without the directories only a single file scripts could be executed. If I understood it correctly. Version from the commit a774fb664deabb6fdb437546038fc9477d291eb1 works, but Python API still uses DFS underneath DistributedCache.
---