[jira] [Created] (FLINK-13274) Refactor HiveTableSource Test using HiveRunner Test Frame
zjuwangg created FLINK-13274: Summary: Refactor HiveTableSource Test using HiveRunner Test Frame Key: FLINK-13274 URL: https://issues.apache.org/jira/browse/FLINK-13274 Project: Flink Issue Type: Test Components: Connectors / Hive Affects Versions: 1.9.0 Reporter: zjuwangg Assignee: zjuwangg Since we have already imported hiveRunner as our hive test environment, it's time to refactor HiveTableSource using hiveRunner to keep consistent. -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql
[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Description: Now in > modify 'use database' syntax in SQL CLI to be consistant with standard sql > -- > > Key: FLINK-13206 > URL: https://issues.apache.org/jira/browse/FLINK-13206 > Project: Flink > Issue Type: Sub-task >Affects Versions: 1.9.0 >Reporter: zjuwangg >Assignee: zjuwangg >Priority: Major > Fix For: 1.9.0 > > > Now in -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql
[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Affects Version/s: 1.9.0 > modify 'use database' syntax in SQL CLI to be consistant with standard sql > -- > > Key: FLINK-13206 > URL: https://issues.apache.org/jira/browse/FLINK-13206 > Project: Flink > Issue Type: Sub-task >Affects Versions: 1.9.0 >Reporter: zjuwangg >Assignee: zjuwangg >Priority: Major > -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql
[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Fix Version/s: 1.9.0 > modify 'use database' syntax in SQL CLI to be consistant with standard sql > -- > > Key: FLINK-13206 > URL: https://issues.apache.org/jira/browse/FLINK-13206 > Project: Flink > Issue Type: Sub-task >Affects Versions: 1.9.0 >Reporter: zjuwangg >Assignee: zjuwangg >Priority: Major > Fix For: 1.9.0 > > -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Created] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql
zjuwangg created FLINK-13206: Summary: modify 'use database' syntax in SQL CLI to be consistant with standard sql Key: FLINK-13206 URL: https://issues.apache.org/jira/browse/FLINK-13206 Project: Flink Issue Type: Sub-task Reporter: zjuwangg Assignee: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Created] (FLINK-13190) add test to verify partition pruning for HiveTableSource
zjuwangg created FLINK-13190: Summary: add test to verify partition pruning for HiveTableSource Key: FLINK-13190 URL: https://issues.apache.org/jira/browse/FLINK-13190 Project: Flink Issue Type: Sub-task Reporter: zjuwangg Assignee: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-13160) HiveTaleSource should implment PartitionableTableSource
zjuwangg created FLINK-13160: Summary: HiveTaleSource should implment PartitionableTableSource Key: FLINK-13160 URL: https://issues.apache.org/jira/browse/FLINK-13160 Project: Flink Issue Type: Sub-task Components: Connectors / Hive Reporter: zjuwangg Assignee: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-13061) Support set hive table Ser/de properites in HiveCatalog
zjuwangg created FLINK-13061: Summary: Support set hive table Ser/de properites in HiveCatalog Key: FLINK-13061 URL: https://issues.apache.org/jira/browse/FLINK-13061 Project: Flink Issue Type: Sub-task Reporter: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-12973) Support reading Hive complex types like array and map
zjuwangg created FLINK-12973: Summary: Support reading Hive complex types like array and map Key: FLINK-12973 URL: https://issues.apache.org/jira/browse/FLINK-12973 Project: Flink Issue Type: Sub-task Reporter: zjuwangg Assignee: zjuwangg HiveTableInputFormat currently only supports reading primitive types. Need to support complex types like array and map. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (FLINK-12966) finalize package name of Hive table source/sink
[ https://issues.apache.org/jira/browse/FLINK-12966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16871951#comment-16871951 ] zjuwangg commented on FLINK-12966: -- +1 > finalize package name of Hive table source/sink > --- > > Key: FLINK-12966 > URL: https://issues.apache.org/jira/browse/FLINK-12966 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Hive >Affects Versions: 1.9.0 >Reporter: Bowen Li >Assignee: zjuwangg >Priority: Major > Fix For: 1.9.0 > > > It's been brought by [~ykt836] and Jeff Zhang that the package name of > `org.apache.flink.batch.connector` may not be proper. > I think @zjuwangg named it this way because most connector packages are named > as org.apache.flink.streaming.connectors.xxx and he is just following the > convention. However, as we are forwarding to streaming-batch unification, we > probably don't need "streaming/batch" in the package names any more, coz, > like file source/sink, hive source/sink can (doesn't mean we necessarily > will) be made as streaming in the future. I'm thinking of just > org.apache.flink.connectors.hive. What do you think? > cc [~ykt836] [~xuefuz] [~lirui] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-12807) Support Hive table columnstats related operations in HiveCatalog
zjuwangg created FLINK-12807: Summary: Support Hive table columnstats related operations in HiveCatalog Key: FLINK-12807 URL: https://issues.apache.org/jira/browse/FLINK-12807 Project: Flink Issue Type: Sub-task Components: Connectors / Hive Affects Versions: 1.9.0 Reporter: zjuwangg Assignee: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (FLINK-12237) Support Hive table stats related operations in HiveCatalog
[ https://issues.apache.org/jira/browse/FLINK-12237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-12237: Assignee: zjuwangg > Support Hive table stats related operations in HiveCatalog > -- > > Key: FLINK-12237 > URL: https://issues.apache.org/jira/browse/FLINK-12237 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API >Reporter: Bowen Li >Assignee: zjuwangg >Priority: Major > Fix For: 1.9.0 > > > Support table stats related operations in HiveCatalog, which implements > ReadableWritableCatalog API -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (FLINK-12572) Implement HiveInputFormat to read Hive tables
[ https://issues.apache.org/jira/browse/FLINK-12572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-12572: - Summary: Implement HiveInputFormat to read Hive tables (was: Implement TableSource and InputFormat to read Hive tables) > Implement HiveInputFormat to read Hive tables > - > > Key: FLINK-12572 > URL: https://issues.apache.org/jira/browse/FLINK-12572 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Hive, Table SQL / Ecosystem >Affects Versions: 1.9.0 >Reporter: zjuwangg >Assignee: zjuwangg >Priority: Major > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-12663) Implement HiveTableSource to read Hive tables
zjuwangg created FLINK-12663: Summary: Implement HiveTableSource to read Hive tables Key: FLINK-12663 URL: https://issues.apache.org/jira/browse/FLINK-12663 Project: Flink Issue Type: Sub-task Components: Connectors / Hive Affects Versions: 1.9.0 Reporter: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (FLINK-12663) Implement HiveTableSource to read Hive tables
[ https://issues.apache.org/jira/browse/FLINK-12663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-12663: Assignee: zjuwangg > Implement HiveTableSource to read Hive tables > - > > Key: FLINK-12663 > URL: https://issues.apache.org/jira/browse/FLINK-12663 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Hive >Affects Versions: 1.9.0 >Reporter: zjuwangg >Assignee: zjuwangg >Priority: Major > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (FLINK-12572) Implement TableSource and InputFormat to read Hive tables
[ https://issues.apache.org/jira/browse/FLINK-12572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-12572: Assignee: zjuwangg > Implement TableSource and InputFormat to read Hive tables > - > > Key: FLINK-12572 > URL: https://issues.apache.org/jira/browse/FLINK-12572 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Hive, Table SQL / Ecosystem >Affects Versions: 1.9.0 >Reporter: zjuwangg >Assignee: zjuwangg >Priority: Major > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-12572) Implement TableSource and InputFormat to read Hive tables
zjuwangg created FLINK-12572: Summary: Implement TableSource and InputFormat to read Hive tables Key: FLINK-12572 URL: https://issues.apache.org/jira/browse/FLINK-12572 Project: Flink Issue Type: Sub-task Components: Connectors / Hive, Table SQL / Ecosystem Affects Versions: 1.9.0 Reporter: zjuwangg -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (FLINK-12236) Support function related operations in HiveCatalog
[ https://issues.apache.org/jira/browse/FLINK-12236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-12236: Assignee: zjuwangg (was: Bowen Li) > Support function related operations in HiveCatalog > -- > > Key: FLINK-12236 > URL: https://issues.apache.org/jira/browse/FLINK-12236 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API >Reporter: Bowen Li >Assignee: zjuwangg >Priority: Major > Fix For: 1.9.0 > > > Support function related operations in HiveCatalog, which implements > ReadableWritableCatalog API -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (FLINK-6924) ADD LOG(X) supported in TableAPI
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-6924: --- Assignee: zjuwangg > ADD LOG(X) supported in TableAPI > > > Key: FLINK-6924 > URL: https://issues.apache.org/jira/browse/FLINK-6924 > Project: Flink > Issue Type: Sub-task > Components: Table API & SQL >Affects Versions: 1.4.0 >Reporter: sunjincheng >Assignee: zjuwangg > Labels: starter > > See FLINK-6891 for detail. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058726#comment-16058726 ] zjuwangg commented on FLINK-6924: - This subtask can be assigned to me if possible, :) > ADD LOG(X) supported in TableAPI > > > Key: FLINK-6924 > URL: https://issues.apache.org/jira/browse/FLINK-6924 > Project: Flink > Issue Type: Sub-task > Components: Table API & SQL >Affects Versions: 1.4.0 >Reporter: sunjincheng > Labels: starter > > See FLINK-6891 for detail. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
