提交 bb62ab08 编写于 作者: M Maximilian Michels 提交者: Stephan Ewen

[FLINK-3569] [build] Adjust test cases due to shading plugin base directory changes

上级 dbe9e596
......@@ -40,7 +40,7 @@ import org.junit.Test;
public class AvroExternalJarProgramITCase {
private static final String JAR_FILE = "target/maven-test-jar.jar";
private static final String JAR_FILE = "maven-test-jar.jar";
private static final String TEST_DATA_FILE = "/testdata.avro";
......
......@@ -50,7 +50,7 @@ import org.apache.flink.storm.api.FlinkTopology;
*/
public class WordCountRemoteByClient {
public final static String topologyId = "Storm WordCount";
private final static String uploadedJarLocation = "target/WordCount-StormTopology.jar";
private final static String uploadedJarLocation = "WordCount-StormTopology.jar";
// *************************************************************************
// PROGRAM
......
......@@ -35,14 +35,6 @@ under the License.
<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>force-shading</artifactId>
<version>1.0.0</version>
<!-- This is necessary to prevent shading of this module -->
<scope>provided</scope>
</dependency>
<!-- BINARIES -->
<dependency>
<groupId>org.apache.flink</groupId>
......@@ -186,6 +178,15 @@ under the License.
</transformers>
</configuration>
</execution>
<execution>
<!--
Disable inherited shade-flink to prevent the Shade plugin from changing the project.basedir. The basedir
is changed by the Shade plugin when dependencyReducedPomLocation is set to a different location than the
original basedir. We do that in the root pom.xml.
-->
<id>shade-flink</id>
<phase>none</phase>
</execution>
</executions>
</plugin>
......
......@@ -155,7 +155,7 @@ class ScalaShellITCase extends TestLogger {
// find jar file that contains the ml code
var externalJar = ""
val folder = new File("../flink-libraries/flink-ml/target/")
val folder = new File("../../flink-libraries/flink-ml/target/")
val listOfFiles = folder.listFiles()
for (i <- listOfFiles.indices) {
......
......@@ -35,15 +35,15 @@ import static org.junit.Assert.fail;
public class ClassLoaderITCase {
private static final String INPUT_SPLITS_PROG_JAR_FILE = "target/customsplit-test-jar.jar";
private static final String INPUT_SPLITS_PROG_JAR_FILE = "customsplit-test-jar.jar";
private static final String STREAMING_INPUT_SPLITS_PROG_JAR_FILE = "target/streaming-customsplit-test-jar.jar";
private static final String STREAMING_INPUT_SPLITS_PROG_JAR_FILE = "streaming-customsplit-test-jar.jar";
private static final String STREAMING_PROG_JAR_FILE = "target/streamingclassloader-test-jar.jar";
private static final String STREAMING_PROG_JAR_FILE = "streamingclassloader-test-jar.jar";
private static final String STREAMING_CHECKPOINTED_PROG_JAR_FILE = "target/streaming-checkpointed-classloader-test-jar.jar";
private static final String STREAMING_CHECKPOINTED_PROG_JAR_FILE = "streaming-checkpointed-classloader-test-jar.jar";
private static final String KMEANS_JAR_PATH = "target/kmeans-test-jar.jar";
private static final String KMEANS_JAR_PATH = "kmeans-test-jar.jar";
@Rule
public TemporaryFolder folder = new TemporaryFolder();
......
......@@ -252,7 +252,7 @@ public abstract class YarnTestBase extends TestLogger {
*
*/
public static void ensureNoProhibitedStringInLogFiles(final String[] prohibited, final String[] whitelisted) {
File cwd = new File("target/"+yarnConfiguration.get(TEST_CLUSTER_NAME_KEY));
File cwd = new File("target/" + yarnConfiguration.get(TEST_CLUSTER_NAME_KEY));
Assert.assertTrue("Expecting directory " + cwd.getAbsolutePath() + " to exist", cwd.exists());
Assert.assertTrue("Expecting directory " + cwd.getAbsolutePath() + " to be a directory", cwd.isDirectory());
......@@ -598,7 +598,7 @@ public abstract class YarnTestBase extends TestLogger {
// The files from there are picked up by the ./tools/travis_watchdog.sh script
// to upload them to Amazon S3.
if(isOnTravis()) {
File target = new File("../target/"+yarnConfiguration.get(TEST_CLUSTER_NAME_KEY));
File target = new File("../target" + yarnConfiguration.get(TEST_CLUSTER_NAME_KEY));
if(!target.mkdirs()) {
LOG.warn("Error creating dirs to {}", target);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册