You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2019/11/12 07:59:01 UTC
[flink] 21/24: revert changes in packagedprogram
This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a commit to branch executors
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4f270911bbf04ecd896574e66f61c36cd8a1e6a1
Author: Kostas Kloudas <kk...@gmail.com>
AuthorDate: Mon Nov 11 14:47:40 2019 +0100
revert changes in packagedprogram
---
.../java/org/apache/flink/client/program/PackagedProgram.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java b/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java
index cbd79b9..2f765b1 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java
@@ -306,16 +306,12 @@ public class PackagedProgram {
* Returns all provided libraries needed to run the program.
*/
public List<URL> getAllLibraries() {
- return getAllLibraries(this.jarFile, this.extractedTempLibraries, isPython);
- }
-
- public static List<URL> getAllLibraries(URL jarFile, List<File> extractedTempLibraries, boolean isPython) {
- List<URL> libs = new ArrayList<URL>(extractedTempLibraries.size() + 1);
+ List<URL> libs = new ArrayList<URL>(this.extractedTempLibraries.size() + 1);
if (jarFile != null) {
libs.add(jarFile);
}
- for (File tmpLib : extractedTempLibraries) {
+ for (File tmpLib : this.extractedTempLibraries) {
try {
libs.add(tmpLib.getAbsoluteFile().toURI().toURL());
}