Repository: flink Updated Branches: refs/heads/release-0.9 c2fcf4542 -> b3429ed55
[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/b3429ed5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b3429ed5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b3429ed5 Branch: refs/heads/release-0.9 Commit: b3429ed553f246605cf068736f568c7f17bade6b Parents: c2fcf45 Author: Maximilian Michels <[email protected]> Authored: Wed Oct 21 10:35:34 2015 +0200 Committer: Maximilian Michels <[email protected]> Committed: Wed Oct 21 10:46:06 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/b3429ed5/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 c278f5c..ee641eb 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 @@ -88,8 +88,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"; }
