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.alva...@udc.es> Authored: Tue Jun 7 19:51:29 2016 +0200 Committer: zentol <ches...@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();
