[jira] [Assigned] (FLINK-12235) Support partition related operations in HiveCatalog

2019-05-17 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-12235: -- Assignee: Rui Li (was: Bowen Li) > Support partition related operations in HiveCatalog >

[jira] [Resolved] (FLINK-12568) Implement OutputFormat to write Hive tables

2019-06-04 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-12568. Resolution: Fixed Fix Version/s: 1.9.0 > Implement OutputFormat to write Hive tables >

[jira] [Resolved] (FLINK-12664) Implement TableSink to write Hive tables

2019-06-04 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-12664. Resolution: Fixed Fix Version/s: 1.9.0 > Implement TableSink to write Hive tables >

[jira] [Updated] (FLINK-12664) Implement TableSink to write Hive tables

2019-06-04 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12664: --- Component/s: Connectors / Hive > Implement TableSink to write Hive tables >

[jira] [Reopened] (FLINK-12664) Implement TableSink to write Hive tables

2019-06-04 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reopened FLINK-12664: Closed by mistake > Implement TableSink to write Hive tables > > >

[jira] [Created] (FLINK-12727) Make HiveTableOutputFormat support writing partitioned tables

2019-06-04 Thread Rui Li (JIRA)
Rui Li created FLINK-12727: -- Summary: Make HiveTableOutputFormat support writing partitioned tables Key: FLINK-12727 URL: https://issues.apache.org/jira/browse/FLINK-12727 Project: Flink Issue

[jira] [Created] (FLINK-12705) Allow user to specify the Hive version in use

2019-06-03 Thread Rui Li (JIRA)
Rui Li created FLINK-12705: -- Summary: Allow user to specify the Hive version in use Key: FLINK-12705 URL: https://issues.apache.org/jira/browse/FLINK-12705 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12664) Implement TableSink to write Hive tables

2019-05-28 Thread Rui Li (JIRA)
Rui Li created FLINK-12664: -- Summary: Implement TableSink to write Hive tables Key: FLINK-12664 URL: https://issues.apache.org/jira/browse/FLINK-12664 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12568) Implement OutputFormat to write Hive tables

2019-05-28 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12568: --- Summary: Implement OutputFormat to write Hive tables (was: Implement TableSink and OutputFormat to write

[jira] [Commented] (FLINK-12568) Implement OutputFormat to write Hive tables

2019-05-28 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850513#comment-16850513 ] Rui Li commented on FLINK-12568: Since {{BatchTableSink}} interface hasn't been finalized, we have

[jira] [Comment Edited] (FLINK-12568) Implement OutputFormat to write Hive tables

2019-05-28 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850513#comment-16850513 ] Rui Li edited comment on FLINK-12568 at 5/29/19 5:22 AM: - Since

[jira] [Assigned] (FLINK-12649) Add a shim layer to support multiple versions of HMS

2019-05-29 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-12649: -- Assignee: Rui Li > Add a shim layer to support multiple versions of HMS >

[jira] [Created] (FLINK-12649) Add a shim layer to support multiple versions of HMS

2019-05-28 Thread Rui Li (JIRA)
Rui Li created FLINK-12649: -- Summary: Add a shim layer to support multiple versions of HMS Key: FLINK-12649 URL: https://issues.apache.org/jira/browse/FLINK-12649 Project: Flink Issue Type:

[jira] [Created] (FLINK-12715) Hive-1.2.1 build is broken

2019-06-03 Thread Rui Li (JIRA)
Rui Li created FLINK-12715: -- Summary: Hive-1.2.1 build is broken Key: FLINK-12715 URL: https://issues.apache.org/jira/browse/FLINK-12715 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Updated] (FLINK-12715) Hive-1.2.1 build is broken

2019-06-03 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12715: --- Component/s: Connectors / Hive > Hive-1.2.1 build is broken > -- > >

[jira] [Updated] (FLINK-12715) Hive-1.2.1 build is broken

2019-06-04 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12715: --- Description: Some Hive util methods used are not compatible between Hive-2.3.4 and Hive-1.2.1. (was: Some

[jira] [Updated] (FLINK-12418) Add input/output format and SerDeLib information when creating Hive table in HiveCatalog

2019-05-27 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12418: --- Summary: Add input/output format and SerDeLib information when creating Hive table in HiveCatalog (was:

[jira] [Assigned] (FLINK-12418) Add input/output format and SerDeLib information for Hive tables in HiveCatalogUtil#createHiveTable

2019-05-27 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-12418: -- Assignee: Rui Li > Add input/output format and SerDeLib information for Hive tables in >

[jira] [Commented] (FLINK-12966) finalize package name of Hive table source/sink

2019-06-24 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16871928#comment-16871928 ] Rui Li commented on FLINK-12966: Sounds good to me > finalize package name of Hive table source/sink >

[jira] [Created] (FLINK-12970) Support writing Hive complex types

2019-06-25 Thread Rui Li (JIRA)
Rui Li created FLINK-12970: -- Summary: Support writing Hive complex types Key: FLINK-12970 URL: https://issues.apache.org/jira/browse/FLINK-12970 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12970) Support writing Hive complex types

2019-06-25 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12970: --- Component/s: Connectors / Hive > Support writing Hive complex types > -- >

[jira] [Updated] (FLINK-12970) Support writing Hive complex types

2019-06-25 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12970: --- Description: HiveTableOutputFormat currently only supports writing primitive types. Need to support complex

[jira] [Updated] (FLINK-12235) Support Hive partition in HiveCatalog

2019-05-21 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12235: --- Summary: Support Hive partition in HiveCatalog (was: Support partition related operations in HiveCatalog)

[jira] [Created] (FLINK-12568) Implement TableSink and OutputFormat to write Hive tables

2019-05-21 Thread Rui Li (JIRA)
Rui Li created FLINK-12568: -- Summary: Implement TableSink and OutputFormat to write Hive tables Key: FLINK-12568 URL: https://issues.apache.org/jira/browse/FLINK-12568 Project: Flink Issue Type:

[jira] [Created] (FLINK-12554) Create TableFactory for Hive connector

2019-05-20 Thread Rui Li (JIRA)
Rui Li created FLINK-12554: -- Summary: Create TableFactory for Hive connector Key: FLINK-12554 URL: https://issues.apache.org/jira/browse/FLINK-12554 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-13068) HiveTableSink should implement PartitionableTableSink

2019-07-03 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13068: --- Component/s: Connectors / Hive > HiveTableSink should implement PartitionableTableSink >

[jira] [Created] (FLINK-13110) Fix Hive-1.2.1 build

2019-07-05 Thread Rui Li (JIRA)
Rui Li created FLINK-13110: -- Summary: Fix Hive-1.2.1 build Key: FLINK-13110 URL: https://issues.apache.org/jira/browse/FLINK-13110 Project: Flink Issue Type: Sub-task Reporter: Rui Li

[jira] [Updated] (FLINK-13110) Fix Hive-1.2.1 build

2019-07-05 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13110: --- Component/s: Connectors / Hive > Fix Hive-1.2.1 build > > > Key:

[jira] [Created] (FLINK-12995) Add Hive-1.2.1 build to Travis

2019-06-26 Thread Rui Li (JIRA)
Rui Li created FLINK-12995: -- Summary: Add Hive-1.2.1 build to Travis Key: FLINK-12995 URL: https://issues.apache.org/jira/browse/FLINK-12995 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12995) Add Hive-1.2.1 build to Travis

2019-06-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12995: --- Component/s: Connectors / Hive > Add Hive-1.2.1 build to Travis > -- > >

[jira] [Created] (FLINK-13170) Planner should get table factory from catalog when creating sink for CatalogTable

2019-07-09 Thread Rui Li (JIRA)
Rui Li created FLINK-13170: -- Summary: Planner should get table factory from catalog when creating sink for CatalogTable Key: FLINK-13170 URL: https://issues.apache.org/jira/browse/FLINK-13170 Project: Flink

[jira] [Created] (FLINK-13068) HiveTableSink should implement PartitionableTableSink

2019-07-02 Thread Rui Li (JIRA)
Rui Li created FLINK-13068: -- Summary: HiveTableSink should implement PartitionableTableSink Key: FLINK-13068 URL: https://issues.apache.org/jira/browse/FLINK-13068 Project: Flink Issue Type:

[jira] [Created] (FLINK-13069) HiveTableSink should implement OverwritableTableSink

2019-07-02 Thread Rui Li (JIRA)
Rui Li created FLINK-13069: -- Summary: HiveTableSink should implement OverwritableTableSink Key: FLINK-13069 URL: https://issues.apache.org/jira/browse/FLINK-13069 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13255) Exclude hive connector from JDK9 profile

2019-07-15 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884892#comment-16884892 ] Rui Li commented on FLINK-13255: I guess we can have a dedicated Travis job for hive connector, and

[jira] [Created] (FLINK-13255) Exclude hive connector from JDK9 profile

2019-07-15 Thread Rui Li (JIRA)
Rui Li created FLINK-13255: -- Summary: Exclude hive connector from JDK9 profile Key: FLINK-13255 URL: https://issues.apache.org/jira/browse/FLINK-13255 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-13255) Exclude hive connector from JDK9 profile

2019-07-15 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13255: --- Description: The Hive binary we depend upon has issues when running with JDK9, e.g. it assumes application

[jira] [Commented] (FLINK-13215) Hive connector does not compile on Java 9

2019-07-15 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885027#comment-16885027 ] Rui Li commented on FLINK-13215: I was trying to encode white spaces in the path. And seems the

[jira] [Commented] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-08-13 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906816#comment-16906816 ] Rui Li commented on FLINK-13653: Just created a PoC pull request to get some feedbacks. It seems we

[jira] [Commented] (FLINK-13549) Unable to query Hive table with char or varchar columns

2019-08-13 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906893#comment-16906893 ] Rui Li commented on FLINK-13549: Seems FLINK-13534 also fixed the issue here. Closing this one. >

[jira] [Closed] (FLINK-13549) Unable to query Hive table with char or varchar columns

2019-08-13 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li closed FLINK-13549. -- Resolution: Fixed > Unable to query Hive table with char or varchar columns >

[jira] [Created] (FLINK-13693) Identifiers are not properly handled in some DDLs

2019-08-12 Thread Rui Li (JIRA)
Rui Li created FLINK-13693: -- Summary: Identifiers are not properly handled in some DDLs Key: FLINK-13693 URL: https://issues.apache.org/jira/browse/FLINK-13693 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13747) Remove some TODOs in Hive connector

2019-08-16 Thread Rui Li (JIRA)
Rui Li created FLINK-13747: -- Summary: Remove some TODOs in Hive connector Key: FLINK-13747 URL: https://issues.apache.org/jira/browse/FLINK-13747 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13741) "SHOW FUNCTIONS" should include Flink built-in functions' names

2019-08-15 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908727#comment-16908727 ] Rui Li commented on FLINK-13741: +1 to include built-in functions for {{SHOW FUNCTIONS}}. On the other

[jira] [Created] (FLINK-13711) Hive array values not properly displayed in SQL CLI

2019-08-14 Thread Rui Li (JIRA)
Rui Li created FLINK-13711: -- Summary: Hive array values not properly displayed in SQL CLI Key: FLINK-13711 URL: https://issues.apache.org/jira/browse/FLINK-13711 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13197) support querying Hive's view in Flink

2019-08-19 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910930#comment-16910930 ] Rui Li commented on FLINK-13197: [~phoenixjiangnan] I suppose this has to wait for FLINK-12905 to get in

[jira] [Created] (FLINK-13814) HiveTableSink should strip quotes from partition values

2019-08-21 Thread Rui Li (Jira)
Rui Li created FLINK-13814: -- Summary: HiveTableSink should strip quotes from partition values Key: FLINK-13814 URL: https://issues.apache.org/jira/browse/FLINK-13814 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13826) Support INSERT OVERWRITE for Hive connector

2019-08-23 Thread Rui Li (Jira)
Rui Li created FLINK-13826: -- Summary: Support INSERT OVERWRITE for Hive connector Key: FLINK-13826 URL: https://issues.apache.org/jira/browse/FLINK-13826 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink

2019-09-04 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922319#comment-16922319 ] Rui Li commented on FLINK-13952: [~lzljs3620320] Thanks for reporting the issue. Let me know if you want

[jira] [Created] (FLINK-14089) SQL CLI doesn't support explain DMLs

2019-09-16 Thread Rui Li (Jira)
Rui Li created FLINK-14089: -- Summary: SQL CLI doesn't support explain DMLs Key: FLINK-14089 URL: https://issues.apache.org/jira/browse/FLINK-14089 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13438) Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support

2019-07-27 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894616#comment-16894616 ] Rui Li commented on FLINK-13438: [~jark] yes, Hive returns `java.sql.Timestamp` for timestamp columns

[jira] [Commented] (FLINK-13279) not able to query table registered in catalogs in SQL CLI

2019-07-30 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896062#comment-16896062 ] Rui Li commented on FLINK-13279: Does this ticket fix blink planner as well? I ran some test with blink

[jira] [Commented] (FLINK-13279) not able to query table registered in catalogs in SQL CLI

2019-07-30 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896087#comment-16896087 ] Rui Li commented on FLINK-13279: [~dawidwys] Thanks for clarifying. I'll double check. > not able to

[jira] [Commented] (FLINK-13475) Reduce dependency on third-party maven repositories

2019-07-30 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896112#comment-16896112 ] Rui Li commented on FLINK-13475: [~Terry1897] I think the pentaho deps are introduced as {{hive-exec -->

[jira] [Commented] (FLINK-13279) not able to query table registered in catalogs in SQL CLI

2019-07-31 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896836#comment-16896836 ] Rui Li commented on FLINK-13279: [~dawidwys] Got it. Thanks for the pointers. > not able to query table

[jira] [Commented] (FLINK-13279) not able to query table registered in catalogs in SQL CLI

2019-07-31 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896809#comment-16896809 ] Rui Li commented on FLINK-13279: Hi [~dawidwys], I was trying something like the following and got

[jira] [Commented] (FLINK-13501) Fixes a few issues in documentation for Hive integration

2019-07-31 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896877#comment-16896877 ] Rui Li commented on FLINK-13501: [~xuefuz] Regarding the catalog page, the hierarchy was fixed as part

[jira] [Commented] (FLINK-13303) Add e2e test for hive connector

2019-07-31 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897717#comment-16897717 ] Rui Li commented on FLINK-13303: [~jark] I'm now allowed to modify the {{Resolution}} field but I think

[jira] [Comment Edited] (FLINK-13303) Add e2e test for hive connector

2019-07-31 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897717#comment-16897717 ] Rui Li edited comment on FLINK-13303 at 8/1/19 2:53 AM: [~jark] I'm not allowed

[jira] [Created] (FLINK-13526) Switching to a non existing database crashes sql-client

2019-08-01 Thread Rui Li (JIRA)
Rui Li created FLINK-13526: -- Summary: Switching to a non existing database crashes sql-client Key: FLINK-13526 URL: https://issues.apache.org/jira/browse/FLINK-13526 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-02 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898825#comment-16898825 ] Rui Li commented on FLINK-13534: [~lzljs3620320] I'm afraid we need to avoid planner-specific code, as

[jira] [Created] (FLINK-13549) Unable to query Hive table with char or varchar columns

2019-08-02 Thread Rui Li (JIRA)
Rui Li created FLINK-13549: -- Summary: Unable to query Hive table with char or varchar columns Key: FLINK-13549 URL: https://issues.apache.org/jira/browse/FLINK-13549 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-02 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898734#comment-16898734 ] Rui Li commented on FLINK-13534: Thanks [~lzljs3620320]. FLINK-13495 seems to help, but I think there's

[jira] [Commented] (FLINK-13352) Using hive connector with hive-1.2.1 needs libfb303 jar

2019-07-28 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894874#comment-16894874 ] Rui Li commented on FLINK-13352: Thanks [~ykt836]. Would you mind also review the PR? This is trivial

[jira] [Commented] (FLINK-13427) HiveCatalog's createFunction fails when function name has upper-case characters

2019-07-28 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894883#comment-16894883 ] Rui Li commented on FLINK-13427: I'll work on it if nobody's working on it yet. > HiveCatalog's

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

2019-08-08 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13526: --- Summary: Switching to a non existing catalog or database crashes sql-client (was: Switching to a non

[jira] [Commented] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-08-08 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903527#comment-16903527 ] Rui Li commented on FLINK-13653: I thought we should just use the new type system for

[jira] [Created] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-01 Thread Rui Li (JIRA)
Rui Li created FLINK-13534: -- Summary: Unable to query Hive table with decimal column Key: FLINK-13534 URL: https://issues.apache.org/jira/browse/FLINK-13534 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-01 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898069#comment-16898069 ] Rui Li commented on FLINK-13534: It seems in {{BatchTableSourceScan.translateToPlan}} the produced type

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-01 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13534: --- Component/s: Connectors / Hive > Unable to query Hive table with decimal column >

[jira] [Commented] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-05 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900601#comment-16900601 ] Rui Li commented on FLINK-13534: [~lzljs3620320] Just verified latest PR of FLINK-13495 fixes the issues

[jira] [Updated] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-08-08 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13653: --- Description: Creating a RowTypeInfo from a TableSchema can lose type parameters. As a result, querying a

[jira] [Updated] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-08-08 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13653: --- Description: Creating a RowTypeInfo from a TableSchema can lose type parameters. For example, querying a

[jira] [Created] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-08-08 Thread Rui Li (JIRA)
Rui Li created FLINK-13653: -- Summary: ResultStore should avoid using RowTypeInfo when creating a result Key: FLINK-13653 URL: https://issues.apache.org/jira/browse/FLINK-13653 Project: Flink Issue

[jira] [Updated] (FLINK-13255) Skip hive connector test for JDK9 profile

2019-07-18 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13255: --- Summary: Skip hive connector test for JDK9 profile (was: Exclude hive connector from JDK9 profile) > Skip

[jira] [Updated] (FLINK-13303) Add e2e test for hive connector

2019-07-17 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13303: --- Fix Version/s: 1.9.0 > Add e2e test for hive connector > --- > >

[jira] [Created] (FLINK-13303) Add e2e test for hive connector

2019-07-17 Thread Rui Li (JIRA)
Rui Li created FLINK-13303: -- Summary: Add e2e test for hive connector Key: FLINK-13303 URL: https://issues.apache.org/jira/browse/FLINK-13303 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-13424) HiveCatalog should add hive version in conf

2019-07-25 Thread Rui Li (JIRA)
Rui Li created FLINK-13424: -- Summary: HiveCatalog should add hive version in conf Key: FLINK-13424 URL: https://issues.apache.org/jira/browse/FLINK-13424 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13413) Put flink-table jar under lib folder

2019-07-24 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892403#comment-16892403 ] Rui Li commented on FLINK-13413: +1 to put the jar in lib. It surprised me when I run some simple SQL

[jira] [Commented] (FLINK-13423) Unable to find function in hive 1

2019-07-25 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892560#comment-16892560 ] Rui Li commented on FLINK-13423: I think I hit the same issue when worked on FLINK-13303. I'll extract

[jira] [Updated] (FLINK-13192) Add tests for different Hive table formats

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13192: --- Priority: Blocker (was: Major) > Add tests for different Hive table formats >

[jira] [Updated] (FLINK-13423) Unable to find function in hive 1

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13423: --- Priority: Blocker (was: Major) > Unable to find function in hive 1 > - > >

[jira] [Updated] (FLINK-13424) HiveCatalog should add hive version in conf

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13424: --- Priority: Blocker (was: Major) > HiveCatalog should add hive version in conf >

[jira] [Updated] (FLINK-13352) Using hive connector with hive-1.2.1 needs libfb303 jar

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13352: --- Priority: Blocker (was: Major) > Using hive connector with hive-1.2.1 needs libfb303 jar >

[jira] [Updated] (FLINK-13012) Handle default partition name of Hive table

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13012: --- Priority: Blocker (was: Major) > Handle default partition name of Hive table >

[jira] [Updated] (FLINK-13012) Handle default partition name of Hive table

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13012: --- Fix Version/s: 1.9.0 > Handle default partition name of Hive table >

[jira] [Commented] (FLINK-13438) Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893758#comment-16893758 ] Rui Li commented on FLINK-13438: [~TsReaper] Not sure if I understand the issue correctly. When creating

[jira] [Commented] (FLINK-13427) HiveCatalog's createFunction not work when function name is upper

2019-07-25 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893309#comment-16893309 ] Rui Li commented on FLINK-13427: This is a bug of Hive metastore API. Name is not normalized when a

[jira] [Created] (FLINK-13352) Using hive connector with hive-1.2.1 needs libfb303 jar

2019-07-22 Thread Rui Li (JIRA)
Rui Li created FLINK-13352: -- Summary: Using hive connector with hive-1.2.1 needs libfb303 jar Key: FLINK-13352 URL: https://issues.apache.org/jira/browse/FLINK-13352 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-14129) HiveTableSource should implement ProjectableTableSource

2019-09-19 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-14129: --- Component/s: Connectors / Hive > HiveTableSource should implement ProjectableTableSource >

[jira] [Created] (FLINK-14129) HiveTableSource should implement ProjectableTableSource

2019-09-19 Thread Rui Li (Jira)
Rui Li created FLINK-14129: -- Summary: HiveTableSource should implement ProjectableTableSource Key: FLINK-14129 URL: https://issues.apache.org/jira/browse/FLINK-14129 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14129) HiveTableSource should implement ProjectableTableSource

2019-09-19 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-14129: --- Description: With projection push down, we can avoid inspecting unused columns in HiveTableInputFormat

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

2019-09-20 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-14148: --- Component/s: Connectors / Hive > Investigate pushing predicate/projection to underlying Hive input format >

[jira] [Created] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

2019-09-20 Thread Rui Li (Jira)
Rui Li created FLINK-14148: -- Summary: Investigate pushing predicate/projection to underlying Hive input format Key: FLINK-14148 URL: https://issues.apache.org/jira/browse/FLINK-14148 Project: Flink

[jira] [Created] (FLINK-13012) Handle default partition name of Hive table

2019-06-27 Thread Rui Li (JIRA)
Rui Li created FLINK-13012: -- Summary: Handle default partition name of Hive table Key: FLINK-13012 URL: https://issues.apache.org/jira/browse/FLINK-13012 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-13012) Handle default partition name of Hive table

2019-06-27 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13012: --- Component/s: Connectors / Hive > Handle default partition name of Hive table >

[jira] [Created] (FLINK-13090) Test Hive connector with hive runner

2019-07-03 Thread Rui Li (JIRA)
Rui Li created FLINK-13090: -- Summary: Test Hive connector with hive runner Key: FLINK-13090 URL: https://issues.apache.org/jira/browse/FLINK-13090 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13192) Add tests for different Hive table formats

2019-07-10 Thread Rui Li (JIRA)
Rui Li created FLINK-13192: -- Summary: Add tests for different Hive table formats Key: FLINK-13192 URL: https://issues.apache.org/jira/browse/FLINK-13192 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-13090) Test Hive connector with hive runner

2019-07-10 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-13090. Resolution: Fixed > Test Hive connector with hive runner > > >

[jira] [Created] (FLINK-14605) Use Hive-1.1.0 as the profile to test against 1.1.x

2019-11-04 Thread Rui Li (Jira)
Rui Li created FLINK-14605: -- Summary: Use Hive-1.1.0 as the profile to test against 1.1.x Key: FLINK-14605 URL: https://issues.apache.org/jira/browse/FLINK-14605 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-14588) Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread Rui Li (Jira)
Rui Li created FLINK-14588: -- Summary: Support Hive version 1.0.0 and 1.0.1 Key: FLINK-14588 URL: https://issues.apache.org/jira/browse/FLINK-14588 Project: Flink Issue Type: Task

  1   2   3   4   5   6   7   8   9   10   >