[FLINK-22167] Partial insert not works when complex fields reorder

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 09/Apr/21 03:49
• Updated: 28/May/21 09:06
• Resolved: 14/Apr/21 08:37

Description

util.tableEnv.executeSql(
  s"""
     |create table partitioned_sink (
     |  `a` INT,
     |  `b` AS `a` + 1,
     |  `c` STRING,
     |  `d` STRING,
     |  `e` DOUBLE,
     |  `f` BIGINT,
     |  `g` INT
     |) PARTITIONED BY (`c`, `d`) with (
     |  'connector' = 'values',
     |  'sink-insert-only' = 'false'
     |)
     |""".stripMargin)

INSERT INTO sink (b,e,a,g,f,c,d) SELECT b,e,a,456,123,c,d FROM MyTable GROUP BY a,b,c,d,e

 

Issue Links

• links to: GitHub Pull Request #15545