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 20:25:24 UTC
flink git commit: [hotfix] Fix CassandraConnectorITCase
Repository: flink
Updated Branches:
refs/heads/master 79b869498 -> b7ee26774
[hotfix] Fix CassandraConnectorITCase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b7ee2677
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b7ee2677
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b7ee2677
Branch: refs/heads/master
Commit: b7ee2677405235d6a68f1ecd6ce47f5c2fa0acb0
Parents: 79b8694
Author: zentol <ch...@apache.org>
Authored: Thu May 25 22:17:32 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Thu May 25 22:17:32 2017 +0200
----------------------------------------------------------------------
.../streaming/connectors/cassandra/CassandraConnectorITCase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b7ee2677/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 95cd86c..f6cc231 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
@@ -445,7 +445,7 @@ public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<Stri
};
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
- DataStream<scala.Tuple1<String>> input = env.fromElements(new scala.Tuple1<>("hello"));
+ DataStream<scala.Tuple1<String>> input = env.fromElements(new scala.Tuple1<>("hello")).returns(typeInfo);
CassandraSink.CassandraSinkBuilder<scala.Tuple1<String>> sinkBuilder = CassandraSink.addSink(input);
assertTrue(sinkBuilder instanceof CassandraSink.CassandraScalaProductSinkBuilder);
@@ -453,7 +453,7 @@ public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<Stri
@Test
public void testCassandraScalaTupleAtLeastSink() throws Exception {
- CassandraScalaProductSink<scala.Tuple3<String, Integer, Integer>> sink = new CassandraScalaProductSink<>(INSERT_DATA_QUERY, builder);
+ CassandraScalaProductSink<scala.Tuple3<String, Integer, Integer>> sink = new CassandraScalaProductSink<>(injectTableName(INSERT_DATA_QUERY), builder);
List<scala.Tuple3<String, Integer, Integer>> scalaTupleCollection = new ArrayList<>(20);
for (int i = 0; i < 20; i++) {