[
https://issues.apache.org/jira/browse/FLINK-22167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-22167:
---------------------------------
Description:
{code:java}
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
{code}
was: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
> Partial insert not works when complex fields reorder
> ----------------------------------------------------
>
> Key: FLINK-22167
> URL: https://issues.apache.org/jira/browse/FLINK-22167
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Reporter: Jingsong Lee
> Assignee: Jingsong Lee
> Priority: Major
> Fix For: 1.13.0
>
>
> {code:java}
> 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
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
