Revert "[hotfix] [cassandra] [tests] Show error log messages" This reverts commit 1adefee2eff9c9b4267f5b5e10022255cfcaf47a.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf785422 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf785422 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cf785422 Branch: refs/heads/master Commit: cf78542232e9bed62fbb1a0de568bf26adbdb098 Parents: a66e7ad Author: Stephan Ewen <[email protected]> Authored: Wed Nov 16 17:58:24 2016 +0100 Committer: Stephan Ewen <[email protected]> Committed: Wed Nov 16 19:08:07 2016 +0100 ---------------------------------------------------------------------- .../connectors/cassandra/CassandraConnectorITCase.java | 6 +----- .../src/test/resources/log4j-test.properties | 2 +- 2 files changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/cf785422/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 acfe848..258ef52 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,11 +161,7 @@ public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<Stri if (EMBEDDED) { if (cassandra != null) { - try { - cassandra.destroy(); - } catch (IllegalStateException ignored) { - // the process was never started - } + cassandra.destroy(); } } } http://git-wip-us.apache.org/repos/asf/flink/blob/cf785422/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 0a630f4..a43d556 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=ERROR, testlogger +log4j.rootLogger=OFF, testlogger log4j.appender.testlogger=org.apache.log4j.ConsoleAppender log4j.appender.testlogger.target= System.err
