amoro icon indicating copy to clipboard operation
amoro copied to clipboard

[Flink] [bug] Logstore serialize ArrayIndexOutOfBoundsException with Localtimestamp system build-in function

Open YesOrNo828 opened this issue 3 years ago • 0 comments

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',
  ......

YesOrNo828 avatar Aug 08 '22 07:08 YesOrNo828