Repository: flink Updated Branches: refs/heads/master 8b2d4f8c7 -> 42a3d8cfa
[FLINK-2885][python] fix path building of Python resources Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42a3d8cf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42a3d8cf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/42a3d8cf Branch: refs/heads/master Commit: 42a3d8cfa9eacc19ac04004b256b6eb51422b523 Parents: 8b2d4f8 Author: Maximilian Michels <[email protected]> Authored: Wed Oct 21 10:35:34 2015 +0200 Committer: Maximilian Michels <[email protected]> Committed: Wed Oct 21 10:35:34 2015 +0200 ---------------------------------------------------------------------- .../flink/languagebinding/api/java/python/PythonPlanBinder.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/42a3d8cf/flink-staging/flink-language-binding/flink-python/src/main/java/org/apache/flink/languagebinding/api/java/python/PythonPlanBinder.java ---------------------------------------------------------------------- diff --git a/flink-staging/flink-language-binding/flink-python/src/main/java/org/apache/flink/languagebinding/api/java/python/PythonPlanBinder.java b/flink-staging/flink-language-binding/flink-python/src/main/java/org/apache/flink/languagebinding/api/java/python/PythonPlanBinder.java index b52de03..5aa1480 100644 --- a/flink-staging/flink-language-binding/flink-python/src/main/java/org/apache/flink/languagebinding/api/java/python/PythonPlanBinder.java +++ b/flink-staging/flink-language-binding/flink-python/src/main/java/org/apache/flink/languagebinding/api/java/python/PythonPlanBinder.java @@ -89,8 +89,7 @@ public class PythonPlanBinder extends PlanBinder<PythonOperationInfo> { FLINK_PYTHON2_BINARY_PATH = GlobalConfiguration.getString(FLINK_PYTHON2_BINARY_KEY, "python"); FLINK_PYTHON3_BINARY_PATH = GlobalConfiguration.getString(FLINK_PYTHON3_BINARY_KEY, "python3"); FULL_PATH = FLINK_DIR != null - //substring is used because the root dir path ends with "/bin/.." - ? FLINK_DIR.substring(0, FLINK_DIR.length() - 7) + FLINK_PYTHON_REL_LOCAL_PATH //command-line + ? FLINK_DIR + "/" + FLINK_PYTHON_REL_LOCAL_PATH //command-line : FileSystem.getLocalFileSystem().getWorkingDirectory().toString() //testing + "/src/main/python/org/apache/flink/languagebinding/api/python"; }
