[#1140] bumped flink version to 1.7.0 (#1142)

fixes #1140
dbs-leipzig · Jan 16, 2019 · 4aa27a6 · 4aa27a6
1 parent 1b37721
commit 4aa27a6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/gradoop-flink/src/test/java/org/gradoop/flink/model/GradoopFlinkTestBase.java b/gradoop-flink/src/test/java/org/gradoop/flink/model/GradoopFlinkTestBase.java
@@ -19,7 +19,6 @@
 import org.apache.flink.api.java.ExecutionEnvironment;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster;
-import org.apache.flink.test.util.TestBaseUtils;
 import org.apache.flink.test.util.TestEnvironment;
 import org.gradoop.common.GradoopTestUtils;
 import org.gradoop.common.model.api.entities.EPGMElement;
@@ -36,7 +35,6 @@
 import org.junit.AfterClass;
 import org.junit.Assert;
 import org.junit.BeforeClass;
-import scala.concurrent.duration.FiniteDuration;
 
 import java.io.File;
 import java.io.IOException;
@@ -46,7 +44,6 @@
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Path;
-import java.util.concurrent.TimeUnit;
 
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
@@ -168,8 +165,8 @@ public static void setupFlink() throws Exception {
   }
 
   @AfterClass
-  public static void tearDownFlink() throws Exception {
-    TestBaseUtils.stopCluster(CLUSTER, new FiniteDuration(1000, TimeUnit.SECONDS));
+  public static void tearDownFlink() {
+    CLUSTER.stop();
   }
 
   //----------------------------------------------------------------------------

diff --git a/pom.xml b/pom.xml
@@ -129,7 +129,7 @@
         <!-- alpha order require -->
         <dep.accumulo.version>1.9.0</dep.accumulo.version>
         <dep.commons-cli.version>1.4</dep.commons-cli.version>
-        <dep.flink.version>1.6.0</dep.flink.version>
+        <dep.flink.version>1.7.0</dep.flink.version>
         <dep.gdl.version>0.3</dep.gdl.version>
         <dep.hbase.version>1.4.3</dep.hbase.version>
         <dep.javafastpfor.version>0.1.10</dep.javafastpfor.version>