You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/07/16 09:35:23 UTC
[flink] branch master updated: [FLINK-13215][hive] Simplify copying
of classpath
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b63bd5d [FLINK-13215][hive] Simplify copying of classpath
b63bd5d is described below
commit b63bd5dda6fa9881a2a3f373f273145ea70a5657
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Jul 16 11:35:04 2019 +0200
[FLINK-13215][hive] Simplify copying of classpath
---
.../flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java | 9 +--------
1 file changed, 1 insertion(+), 8 deletions(-)
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java
index 1df9904..dbc7757 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/hive/FlinkStandaloneHiveRunner.java
@@ -22,7 +22,6 @@ import org.apache.flink.table.catalog.hive.HiveTestUtils;
import org.apache.flink.util.Preconditions;
import org.apache.flink.shaded.guava18.com.google.common.base.Joiner;
-import org.apache.flink.shaded.guava18.com.google.common.base.Splitter;
import org.apache.flink.shaded.guava18.com.google.common.base.Throwables;
import org.apache.flink.shaded.guava18.com.google.common.io.Resources;
@@ -53,7 +52,6 @@ import org.junit.runners.model.InitializationError;
import org.junit.runners.model.Statement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import sun.net.www.ParseUtil;
import java.io.BufferedReader;
import java.io.File;
@@ -353,13 +351,8 @@ public class FlinkStandaloneHiveRunner extends BlockJUnit4ClassRunner {
String javaHome = System.getProperty("java.home");
args.add(Joiner.on(File.separator).join(javaHome, "bin", "java"));
// set classpath
- List<String> cpElements = new ArrayList<>();
- String classpath = System.getProperty("java.class.path");
- for (String path : Splitter.on(File.pathSeparator).split(classpath)) {
- cpElements.add(ParseUtil.encodePath(path));
- }
args.add("-cp");
- args.add(String.join(File.pathSeparator, cpElements));
+ args.add(System.getProperty("java.class.path"));
// set sys properties
// TODO: generate hive-site.xml at runtime?