flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [1/2] flink git commit: [hotfix] [py] Fix PythonPlanBinder not copying additional files
Date Fri, 10 Jun 2016 12:08:12 GMT
Repository: flink
Updated Branches:
  refs/heads/master 8696e799f -> 76dcbd458


[hotfix] [py] Fix PythonPlanBinder not copying additional files


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e90ea9cf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e90ea9cf
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e90ea9cf

Branch: refs/heads/master
Commit: e90ea9cfb030f938fc4165b907919e9f4aba01a4
Parents: 8696e79
Author: omaralvarez <omar.alvarez@udc.es>
Authored: Tue Jun 7 19:51:29 2016 +0200
Committer: zentol <chesnay@apache.org>
Committed: Fri Jun 10 14:04:24 2016 +0200

----------------------------------------------------------------------
 .../main/java/org/apache/flink/python/api/PythonPlanBinder.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/e90ea9cf/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonPlanBinder.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonPlanBinder.java
b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonPlanBinder.java
index f43a4f9..0c1781a 100644
--- a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonPlanBinder.java
+++ b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonPlanBinder.java
@@ -135,7 +135,7 @@ public class PythonPlanBinder {
 
 		try {
 			String tmpPath = FLINK_PYTHON_FILE_PATH + r.nextInt();
-			prepareFiles(tmpPath, Arrays.copyOfRange(args, 0, split == 0 ? 1 : split));
+			prepareFiles(tmpPath, Arrays.copyOfRange(args, 0, split == 0 ? args.length : split));
 			startPython(tmpPath, Arrays.copyOfRange(args, split == 0 ? args.length : split + 1, args.length));
 			receivePlan();
 


Mime
View raw message