You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/05/11 10:25:00 UTC
[jira] [Updated] (FLINK-17614) Add project ITCase for partition
table in filesystem connector
[ https://issues.apache.org/jira/browse/FLINK-17614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu updated FLINK-17614:
-------------------------------
Description:
create table partitionedTable (
x string,
y int,
a int,
b bigint
) partitioned by (a, b) with (
'connector' = 'filesystem',
...
)
Add ITCase that project field from general field(x, y) and partition key field(a, b) to validate
project and default partition value works well like:
check(
"select y, b, x from partitionedTable where a=3",
Seq(
row(17, 1, "x17"),
row(18, 2, "x18"),
row(19, 3, "x19")
))
was:
create table partitionedTable (
| x string,
| y int,
| a int,
| b bigint
|) partitioned by (a, b) with (
| 'connector' = 'filesystem',
...
)
Add ITCase that project field from general field(x, y) and partition key field(a, b) to validate
project and default partition value works well.
check(
"select y, b, x from partitionedTable where a=3",
Seq(
row(17, 1, "x17"),
row(18, 2, "x18"),
row(19, 3, "x19")
)
)
> Add project ITCase for partition table in filesystem connector
> ---------------------------------------------------------------
>
> Key: FLINK-17614
> URL: https://issues.apache.org/jira/browse/FLINK-17614
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / FileSystem
> Affects Versions: 1.11.0
> Reporter: Leonard Xu
> Priority: Major
> Fix For: 1.11.0
>
>
> create table partitionedTable (
> x string,
> y int,
> a int,
> b bigint
> ) partitioned by (a, b) with (
> 'connector' = 'filesystem',
> ...
> )
> Add ITCase that project field from general field(x, y) and partition key field(a, b) to validate
> project and default partition value works well like:
> check(
> "select y, b, x from partitionedTable where a=3",
> Seq(
> row(17, 1, "x17"),
> row(18, 2, "x18"),
> row(19, 3, "x19")
> ))
--
This message was sent by Atlassian Jira
(v8.3.4#803005)