chixiaopao opened a new issue, #4924:
URL: https://github.com/apache/iceberg/issues/4924
flink version: 1.14.4
iceberg version: 0.13.1
idea test use hadoop catalog.
example：
```
env.executeSql(
s"""
|CREATE CATALOG `$catalog` WITH (
| 'type'='iceberg',
| 'catalog-type'='hadoop',
| 'warehouse'='$basePath',
| 'property-version'='1'
|)
|""".stripMargin
)
env.useCatalog(catalog)
env.useDatabase(database)
```
create table :
```
env.executeSql(
s"""
|CREATE TABLE IF NOT EXISTS
`$catalog`.`$database`.`ods__cs__session_text_slice_d_i`
|(
| `dateId` STRING COMMENT '分区时间',
| `tagGcode` ARRAY<STRING> COMMENT
'标签gcode列表',
| `windowsTagIds` ARRAY<STRING> COMMENT
'窗口标签ID列表',
| `windowTag` STRING COMMENT '窗口标签',
| `create_time` TIMESTAMP COMMENT '数据创建时间'
|) PARTITIONED BY (dateId)
|WITH (
| 'format-version' = '2',
| 'write.upsert.enabled' = 'false',
| 'write.distribution-mode' = 'hash',
| 'write.metadata.delete-after-commit.enabled' = 'true',
| 'write.parquet.row-group-size-bytes' = '134217728',
| 'write.target-file-size-bytes' = '536870912',
| 'history.expire.max-snapshot-age-ms' = '360000',
| 'write.metadata.previous-versions-max' = '5',
| 'write.parallelism' = '1'
|)
|""".stripMargin
)
```
insert data:
```
env.executeSql(
s"""
|INSERT INTO
`$catalog`.`$database`.`ods__cs__session_text_slice_d_i` VALUES(
|'2022-05-31',
|Array['gcode'],
|Array['window_tag_id'],
|'window_tag',
|to_timestamp('2022-05-31 18:00:00')
|)
|""".stripMargin
)
```
select:
```
env.executeSql(
s"""
|INSERT INTO
`$catalog`.`$database`.`ods__cs__session_text_slice_d_i` VALUES(
|'2022-05-31',
|Array['gcode'],
|Array['window_tag_id'],
|'window_tag',
|to_timestamp('2022-05-31 18:00:00')
|)
|""".stripMargin
)
```
result:
```
+--------------------------------+--------------------------------+
| tagGcode | windowsTagIds |
+--------------------------------+--------------------------------+
| [gcode] | [gcode] |
+--------------------------------+--------------------------------+
```
why? is this bug?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
