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 <chesnay@apache.org>
Authored: Sun Feb 18 21:48:55 2018 +0100
Committer: zentol <chesnay@apache.org>
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);
|