This is an automated email from the ASF dual-hosted git repository.
namelchev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 3fb24c6 IGNITE-14007 Fixes unclosed Ignite instance in Flink
integration tests. (#36)
3fb24c6 is described below
commit 3fb24c6121d02fac419bf7e1ba5e9d3622c1459c
Author: Mikhail Petrov <[email protected]>
AuthorDate: Thu Jan 28 14:43:54 2021 +0300
IGNITE-14007 Fixes unclosed Ignite instance in Flink integration tests.
(#36)
---
.../org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java | 8 ++++++++
1 file changed, 8 insertions(+)
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 java.util.Map;
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 @@ public class FlinkIgniteSinkSelfTest {
/** 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();
