You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/10/21 10:45:49 UTC
flink git commit: [FLINK-2885][python] fix path building of Python
resources
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 <mx...@apache.org>
Authored: Wed Oct 21 10:35:34 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
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";
}