(flink-connector-kudu) 11/44: [BAHIR-207] Add tests for scala 2.12 on travis (#59)

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kudu.git

commit 47133a3e4873c0a4295ed4c002d805fbd3304408
Author: Joao Boto <b...@boto.pro>
AuthorDate: Thu Jul 4 00:13:51 2019 +0200

    [BAHIR-207] Add tests for scala 2.12 on travis (#59)
---
 .../apache/flink/streaming/connectors/kudu/KuduOuputFormatTest.java | 6 +++---
 .../org/apache/flink/streaming/connectors/kudu/KuduSinkTest.java    | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduOuputFormatTest.java
 
b/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduOuputFormatTest.java
index b9aaa40..4e91310 100644
--- 
a/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduOuputFormatTest.java
+++ 
b/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduOuputFormatTest.java
@@ -45,7 +45,7 @@ public class KuduOuputFormatTest extends KuduDatabase {
     public void testNotTableExist() throws IOException {
         String masterAddresses = harness.getMasterAddressesAsString();
         KuduTableInfo tableInfo = 
booksTableInfo(UUID.randomUUID().toString(),false);
-        KuduOutputFormat outputFormat = new 
KuduOutputFormat<>(masterAddresses, tableInfo, new DefaultSerDe());
+        KuduOutputFormat<KuduRow> outputFormat = new 
KuduOutputFormat<>(masterAddresses, tableInfo, new DefaultSerDe());
         Assertions.assertThrows(UnsupportedOperationException.class, () -> 
outputFormat.open(0,1));
     }
 
@@ -54,7 +54,7 @@ public class KuduOuputFormatTest extends KuduDatabase {
         String masterAddresses = harness.getMasterAddressesAsString();
 
         KuduTableInfo tableInfo = 
booksTableInfo(UUID.randomUUID().toString(),true);
-        KuduOutputFormat outputFormat = new 
KuduOutputFormat<>(masterAddresses, tableInfo, new DefaultSerDe())
+        KuduOutputFormat<KuduRow> outputFormat = new 
KuduOutputFormat<>(masterAddresses, tableInfo, new DefaultSerDe())
                 .withStrongConsistency();
         outputFormat.open(0,1);
 
@@ -74,7 +74,7 @@ public class KuduOuputFormatTest extends KuduDatabase {
         String masterAddresses = harness.getMasterAddressesAsString();
 
         KuduTableInfo tableInfo = 
booksTableInfo(UUID.randomUUID().toString(),true);
-        KuduOutputFormat outputFormat = new 
KuduOutputFormat<>(masterAddresses, tableInfo, new DefaultSerDe())
+        KuduOutputFormat<KuduRow> outputFormat = new 
KuduOutputFormat<>(masterAddresses, tableInfo, new DefaultSerDe())
                 .withEventualConsistency();
         outputFormat.open(0,1);
 
diff --git 
a/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduSinkTest.java
 
b/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduSinkTest.java
index 83e060d..225bf7c 100644
--- 
a/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduSinkTest.java
+++ 
b/flink-connector-kudu/src/test/java/org/apache/flink/streaming/connectors/kudu/KuduSinkTest.java
@@ -58,7 +58,7 @@ public class KuduSinkTest extends KuduDatabase {
     public void testNotTableExist() throws IOException {
         String masterAddresses = harness.getMasterAddressesAsString();
         KuduTableInfo tableInfo = 
booksTableInfo(UUID.randomUUID().toString(),false);
-        KuduSink sink = new KuduSink<>(masterAddresses, tableInfo, new 
DefaultSerDe());
+        KuduSink<KuduRow> sink = new KuduSink<>(masterAddresses, tableInfo, 
new DefaultSerDe());
         sink.setRuntimeContext(context);
         Assertions.assertThrows(UnsupportedOperationException.class, () -> 
sink.open(new Configuration()));
     }
@@ -68,7 +68,7 @@ public class KuduSinkTest extends KuduDatabase {
         String masterAddresses = harness.getMasterAddressesAsString();
 
         KuduTableInfo tableInfo = 
booksTableInfo(UUID.randomUUID().toString(),true);
-        KuduSink sink = new KuduSink<>(masterAddresses, tableInfo, new 
DefaultSerDe())
+        KuduSink<KuduRow> sink = new KuduSink<>(masterAddresses, tableInfo, 
new DefaultSerDe())
                 .withStrongConsistency();
         sink.setRuntimeContext(context);
         sink.open(new Configuration());
@@ -88,7 +88,7 @@ public class KuduSinkTest extends KuduDatabase {
         String masterAddresses = harness.getMasterAddressesAsString();
 
         KuduTableInfo tableInfo = 
booksTableInfo(UUID.randomUUID().toString(),true);
-        KuduSink sink = new KuduSink<>(masterAddresses, tableInfo, new 
DefaultSerDe())
+        KuduSink<KuduRow> sink = new KuduSink<>(masterAddresses, tableInfo, 
new DefaultSerDe())
                 .withEventualConsistency();
         sink.setRuntimeContext(context);
         sink.open(new Configuration());