Repository: flink Updated Branches: refs/heads/master 74bb7bb63 -> 1adefee2e
[hotfix] [cassandra] [tests] Show error log messages Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1adefee2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1adefee2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1adefee2 Branch: refs/heads/master Commit: 1adefee2eff9c9b4267f5b5e10022255cfcaf47a Parents: 74bb7bb Author: zentol <[email protected]> Authored: Tue Nov 15 14:28:12 2016 +0100 Committer: zentol <[email protected]> Committed: Tue Nov 15 14:28:12 2016 +0100 ---------------------------------------------------------------------- .../connectors/cassandra/CassandraConnectorITCase.java | 6 +++++- .../src/test/resources/log4j-test.properties | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/1adefee2/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 258ef52..acfe848 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 @@ -161,7 +161,11 @@ public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<Stri if (EMBEDDED) { if (cassandra != null) { - cassandra.destroy(); + try { + cassandra.destroy(); + } catch (IllegalStateException ignored) { + // the process was never started + } } } } http://git-wip-us.apache.org/repos/asf/flink/blob/1adefee2/flink-streaming-connectors/flink-connector-cassandra/src/test/resources/log4j-test.properties ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-cassandra/src/test/resources/log4j-test.properties b/flink-streaming-connectors/flink-connector-cassandra/src/test/resources/log4j-test.properties index a43d556..0a630f4 100644 --- a/flink-streaming-connectors/flink-connector-cassandra/src/test/resources/log4j-test.properties +++ b/flink-streaming-connectors/flink-connector-cassandra/src/test/resources/log4j-test.properties @@ -16,7 +16,7 @@ # limitations under the License. ################################################################################ -log4j.rootLogger=OFF, testlogger +log4j.rootLogger=ERROR, testlogger log4j.appender.testlogger=org.apache.log4j.ConsoleAppender log4j.appender.testlogger.target= System.err
