Repository: flink Updated Branches: refs/heads/master 3a4e89643 -> 8cea2f657
[FLINK-8693][py] Remove redundant Intepreter initialization Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8cea2f65 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8cea2f65 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8cea2f65 Branch: refs/heads/master Commit: 8cea2f6576da713e5625e00ef2dbe34a410a1df1 Parents: 3a4e896 Author: zentol <[email protected]> Authored: Sun Feb 18 21:48:55 2018 +0100 Committer: zentol <[email protected]> Committed: Sun Feb 18 21:48:55 2018 +0100 ---------------------------------------------------------------------- .../org/apache/flink/streaming/python/util/InterpreterUtils.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/8cea2f65/flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/InterpreterUtils.java ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/InterpreterUtils.java b/flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/InterpreterUtils.java index 8c3520d..5a39efb 100644 --- a/flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/InterpreterUtils.java +++ b/flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/InterpreterUtils.java @@ -107,8 +107,6 @@ public class InterpreterUtils { fullArgs[0] = scriptDirectory.resolve(scriptName).toString(); System.arraycopy(args, 0, fullArgs, 1, args.length); - initPythonInterpreter(fullArgs, scriptDirectory.toUri().getPath(), scriptName); - PythonInterpreter pythonInterpreter = initPythonInterpreter(fullArgs, scriptDirectory.toUri().getPath(), scriptName); pythonInterpreter.set("__flink_env_factory__", factory);
