amoro
amoro copied to clipboard
[Flink] [bug] Logstore serialize ArrayIndexOutOfBoundsException with Localtimestamp system build-in function
insert into arctic.db.table /*+ OPTIONS('arctic.emit.mode'='log') select id,name, LOCALTIMESTMAP from source;
arctic.db.table table info:
Flink SQL> show create table log_table;
CREATE TABLE `arctic`.`db`.`log_table` (
`id` INT NOT NULL,
`name` VARCHAR(2147483647),
`ts` TIMESTAMP(3),
CONSTRAINT `41b0c2e1-dda2-468b-ad39-ccee3af21aec` PRIMARY KEY (`id`) NOT ENFORCED
) WITH (
'log-store.enable' = 'true',
'log-store.data-format' = 'json',
'table.create-timestamp' = '1659603126358',
'format-version' = '2',
'format' = 'json',
......