You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "zhengshubin (Jira)" <ji...@apache.org> on 2022/12/07 08:18:00 UTC

[jira] [Created] (FLINK-30320) hbase connector insert timestamp type error

zhengshubin created FLINK-30320:
-----------------------------------

             Summary: hbase connector insert timestamp  type error
                 Key: FLINK-30320
                 URL: https://issues.apache.org/jira/browse/FLINK-30320
             Project: Flink
          Issue Type: Bug
          Components: API / DataStream
    Affects Versions: 1.15.2
         Environment: flink 1.15.2

hbase 2.4.1
            Reporter: zhengshubin


hbase table :

CREATE TABLE h_code_wip(
 rowkey STRING,
 info ROW<code_event_time TIMESTAMP>

) WITH (
 'connector' = 'hbase-2.2',
 'table-name' = 'default:code_wip',
 'zookeeper.quorum' = 'xx:2181" 
 )

insert sql:

INSERT INTO h_code_wip

SELECT 
rowkey,
ROW(  CAST (code_event_time AS TIMESTAMP(3)) ) info

FROM code_wip

code_event_time is JAVA Timestamp type  before  I had transform datastream to table.

Whatever I  had cast  code_event_time or not, it occur error:

The precision 6 of TIMESTAMP type is out of the range [0, 3] supported by HBase connector

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)