From d0e52954b035cd4e8cd25962500b3ebb57561f39 Mon Sep 17 00:00:00 2001 From: zentol Date: Sat, 8 Jul 2017 08:44:05 +0200 Subject: [PATCH] [FLINK-7111] [scala-shell] Disable external jar test This closes #4288. --- flink-scala-shell/pom.xml | 55 ------------------- .../flink/api/scala/ScalaShellITCase.scala | 14 ++++- 2 files changed, 11 insertions(+), 58 deletions(-) diff --git a/flink-scala-shell/pom.xml b/flink-scala-shell/pom.xml index e3126991235bc..6f490e44eed53 100644 --- a/flink-scala-shell/pom.xml +++ b/flink-scala-shell/pom.xml @@ -242,61 +242,6 @@ under the License. - - maven-assembly-plugin - 2.4 - - - create-library-loading-jar - process-test-classes - - single - - - - - - - - customjar - false - - src/test/assembly/test-scalashell-customjar-assembly.xml - - - - - - - - - - maven-clean-plugin - 2.5 - - - remove-classloading-test-dependencies - process-test-classes - - clean - - - true - - - ${project.build.testOutputDirectory} - - **/jar/*.class - - - - - - - - diff --git a/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala b/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala index ce08304395c0c..b4ccfaaae7da1 100644 --- a/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala +++ b/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala @@ -26,7 +26,7 @@ import org.apache.flink.runtime.minicluster.StandaloneMiniCluster import org.apache.flink.configuration.{ConfigConstants, Configuration, GlobalConfiguration} import org.apache.flink.test.util.TestBaseUtils import org.apache.flink.util.TestLogger -import org.junit.{AfterClass, Assert, BeforeClass, Test} +import org.junit.{AfterClass, Assert, BeforeClass, Ignore, Test} import scala.concurrent.{Await, Future} import scala.concurrent.duration.FiniteDuration @@ -164,7 +164,11 @@ class ScalaShellITCase extends TestLogger { Assert.assertTrue(output.contains("WC(world,10)")) } - /** Submit external library */ + /** + * Submit external library. + * Disabled due to FLINK-7111. + */ + @Ignore @Test def testSubmissionOfExternalLibraryBatch: Unit = { val input = @@ -184,7 +188,11 @@ class ScalaShellITCase extends TestLogger { Assert.assertTrue(output.contains("\nHELLO 42")) } - /** Submit external library */ + /** + * Submit external library. + * Disabled due to FLINK-7111. + */ + @Ignore @Test def testSubmissionOfExternalLibraryStream: Unit = { val input =