flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [FLINK-8693][py] Remove redundant Intepreter initialization
Date Sun, 18 Feb 2018 20:51:05 GMT
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);


Mime
View raw message