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 2017/05/25 21:04:13 UTC
flink git commit: [hotfix] Really fix CassandraConnectorITCase
Repository: flink
Updated Branches:
refs/heads/master b7ee26774 -> 6771a4d18
[hotfix] Really fix CassandraConnectorITCase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6771a4d1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6771a4d1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6771a4d1
Branch: refs/heads/master
Commit: 6771a4d18eb23c15d51171e58ae13260492c0d8b
Parents: b7ee267
Author: zentol <ch...@apache.org>
Authored: Thu May 25 23:03:30 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Thu May 25 23:03:30 2017 +0200
----------------------------------------------------------------------
flink-connectors/flink-connector-cassandra/.toDelete | 0
.../streaming/connectors/cassandra/CassandraConnectorITCase.java | 2 +-
2 files changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6771a4d1/flink-connectors/flink-connector-cassandra/.toDelete
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-cassandra/.toDelete b/flink-connectors/flink-connector-cassandra/.toDelete
new file mode 100644
index 0000000..e69de29
http://git-wip-us.apache.org/repos/asf/flink/blob/6771a4d1/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
index f6cc231..e6924a3 100644
--- a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
+++ b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
@@ -466,7 +466,7 @@ public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<Stri
}
sink.close();
- ResultSet rs = session.execute(SELECT_DATA_QUERY);
+ ResultSet rs = session.execute(injectTableName(SELECT_DATA_QUERY));
List<Row> rows = rs.all();
assertEquals(scalaTupleCollection.size(), rows.size());