[flink-connector-hbase] 01/02: [FLINK-30386] Fix the issue that column constraint lacks primary key not enforced check

[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-hbase.git

commit fa33afbeba3770e3d9e107975874f10968ef8b6a
Author: Jane Chan <55568005+ladyfor...@users.noreply.github.com>
AuthorDate: Tue Feb 7 15:14:47 2023 +0800

    [FLINK-30386] Fix the issue that column constraint lacks primary key not 
enforced check
    
    This closes #21507
---
 .../java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java    | 2 +-
 .../java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java
 
b/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java
index 1ad2dd2..35be358 100644
--- 
a/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java
+++ 
b/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java
@@ -152,7 +152,7 @@ public class HBaseConnectorITCase extends HBaseTestBase {
 
         tEnv.executeSql(
                 "CREATE TABLE hTable ("
-                        + " rowkey INT PRIMARY KEY,"
+                        + " rowkey INT PRIMARY KEY NOT ENFORCED,"
                         + " family2 ROW<col1 STRING, col2 BIGINT>,"
                         + " family3 ROW<col1 DOUBLE, col2 BOOLEAN, col3 
STRING>,"
                         + " family1 ROW<col1 INT>"
diff --git 
a/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
 
b/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
index e75d0d0..fbd7b2c 100644
--- 
a/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
+++ 
b/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
@@ -168,7 +168,7 @@ public class HBaseConnectorITCase extends HBaseTestBase {
 
         tEnv.executeSql(
                 "CREATE TABLE hTable ("
-                        + " rowkey INT PRIMARY KEY,"
+                        + " rowkey INT PRIMARY KEY NOT ENFORCED,"
                         + " family2 ROW<col1 STRING, col2 BIGINT>,"
                         + " family3 ROW<col1 DOUBLE, col2 BOOLEAN, col3 
STRING>,"
                         + " family1 ROW<col1 INT>"