flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [hotfix] Really fix CassandraConnectorITCase
Date Thu, 25 May 2017 21:04:13 GMT
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 <chesnay@apache.org>
Authored: Thu May 25 23:03:30 2017 +0200
Committer: zentol <chesnay@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());
 


Mime
View raw message