[hotfix][hbase] Add missed ITCase in hbase2 connector

is · Nov 10, 2020 · d6f53f1 · d6f53f1
1 parent a9a0032
commit d6f53f1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...ector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java b/...ector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java
@@ -395,7 +395,7 @@ public void testTableSourceSinkWithDDL() throws Exception {
  StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment();
  StreamTableEnvironment tEnv = StreamTableEnvironment.create(execEnv, streamSettings);
 
- // regiter HBase table testTable1 which contains test data
+ // register HBase table testTable1 which contains test data
  String table1DDL = createHBaseTableDDL(TEST_TABLE_1, true);
  tEnv.executeSql(table1DDL);
 

diff --git a/...ector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java b/...ector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
@@ -247,6 +247,7 @@ public void testTableSourceFieldOrder() {
  TestBaseUtils.compareResultAsText(results, expected);
  }
 
+ @Test
  public void testTableSourceWithTableAPI() throws Exception {
  StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment();
  StreamTableEnvironment tEnv = StreamTableEnvironment.create(execEnv, streamSettings);
@@ -397,7 +398,7 @@ public void testTableSourceSinkWithDDL() throws Exception {
  StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment();
  StreamTableEnvironment tEnv = StreamTableEnvironment.create(execEnv, streamSettings);
 
- // regiter HBase table testTable1 which contains test data
+ // register HBase table testTable1 which contains test data
  String table1DDL = createHBaseTableDDL(TEST_TABLE_1, true);
  tEnv.executeSql(table1DDL);