You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/11/15 13:28:39 UTC
flink git commit: [hotfix] [cassandra] [tests] Show error log messages
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 <ch...@apache.org>
Authored: Tue Nov 15 14:28:12 2016 +0100
Committer: zentol <ch...@apache.org>
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