commit 3fb24c6121d02fac419bf7e1ba5e9d3622c1459c
author Mikhail Petrov <32207922+ololo3000@users.noreply.github.com> Thu Jan 28 14:43:54 2021 +0300
committer GitHub <noreply@github.com> Thu Jan 28 14:43:54 2021 +0300
tree 0c0603d06fd81b37b66cbef5bd9b2537f64ae3bf
parent b26933d178833801d8a251ad1b78dc8057c570cb

IGNITE-14007 Fixes unclosed Ignite instance in Flink integration tests. (#36)

modules/flink-ext/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java

diff --git a/modules/flink-ext/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java b/modules/flink-ext/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
index 14798ed..ef7ce2a 100644
--- a/modules/flink-ext/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
+++ b/modules/flink-ext/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
@@ -22,6 +22,8 @@
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.apache.ignite.Ignition;
+import org.junit.AfterClass;
 import org.junit.Test;
 
 import static org.junit.Assert.assertEquals;
@@ -37,6 +39,12 @@
     /** Ignite test configuration file. */
     private static final String GRID_CONF_FILE = "config/example-ignite.xml";
 
+    /** */
+    @AfterClass
+    public static void afterTests() {
+        Ignition.stopAll(true);
+    }
+
     @Test
     public void testIgniteSink() throws Exception {
         Configuration configuration = new Configuration();