You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/05/12 06:41:00 UTC
[jira] [Assigned] (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 ]
Jingsong Lee reassigned FLINK-17614:
------------------------------------
Assignee: Jingsong Lee
> 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
> Assignee: Jingsong Lee
> 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)