Repository: flink Updated Branches: refs/heads/master cb89ba19b -> e1443d702
[hotfix] [tests] Fix CassandraConnectorITCase on Java 7 profiles Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e1443d70 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e1443d70 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e1443d70 Branch: refs/heads/master Commit: e1443d7025709ac5a9a13bc73e6d7dcec1ba729a Parents: cb89ba1 Author: Stephan Ewen <se...@apache.org> Authored: Thu Sep 1 11:54:18 2016 +0200 Committer: Stephan Ewen <se...@apache.org> Committed: Thu Sep 1 11:54:18 2016 +0200 ---------------------------------------------------------------------- .../connectors/cassandra/CassandraConnectorITCase.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/e1443d70/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java b/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java index 4822f91..8bb440c 100644 --- a/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java +++ b/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java @@ -211,7 +211,10 @@ public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<Stri @AfterClass public static void stopFlink() { - flinkCluster.stop(); + if (flinkCluster != null) { + flinkCluster.stop(); + flinkCluster = null; + } } @AfterClass
