[jira] [Commented] (FLINK-5832) Support for simple hive UDF

[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986562#comment-16986562 ] Xuefu Zhang commented on FLINK-5832: Yeah, this has already completed in Flink 1.10. Thanks. >

[jira] [Comment Edited] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931685#comment-16931685 ] Xuefu Zhang edited comment on FLINK-14098 at 9/17/19 5:34 PM: -- Yeah, this

[jira] [Commented] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931685#comment-16931685 ] Xuefu Zhang commented on FLINK-14098: - Yeah, this is indeed a dupe of FLINK-12845, but thanks for

[jira] [Updated] (FLINK-14005) Support Hive version 2.2.0

[ https://issues.apache.org/jira/browse/FLINK-14005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-14005: Description: (was: Including 2.0.0 and 2.0.1.) > Support Hive version 2.2.0 >

[jira] [Created] (FLINK-14005) Support Hive version 2.2.0

Xuefu Zhang created FLINK-14005: --- Summary: Support Hive version 2.2.0 Key: FLINK-14005 URL: https://issues.apache.org/jira/browse/FLINK-14005 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

[ https://issues.apache.org/jira/browse/FLINK-13998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13998: Description: Our test is using local file system, and orc in HIve 2.0.x seems having issue with

[jira] [Updated] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

[ https://issues.apache.org/jira/browse/FLINK-13998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13998: Labels: (was: pull-request-available) > Fix ORC test failure with Hive 2.0.x >

[jira] [Created] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

Xuefu Zhang created FLINK-13998: --- Summary: Fix ORC test failure with Hive 2.0.x Key: FLINK-13998 URL: https://issues.apache.org/jira/browse/FLINK-13998 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13947) Check Hive shim serialization in Hive UDF wrapper classes and test coverage

[ https://issues.apache.org/jira/browse/FLINK-13947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13947: Description: Check 1. if HiveShim needs to be serializable and serialized in a few Hive UDF

[jira] [Created] (FLINK-13947) Check Hive shim serialization in Hive UDF wrapper classes and test coverage

Xuefu Zhang created FLINK-13947: --- Summary: Check Hive shim serialization in Hive UDF wrapper classes and test coverage Key: FLINK-13947 URL: https://issues.apache.org/jira/browse/FLINK-13947 Project:

[jira] [Updated] (FLINK-13931) Support Hive version 2.0.x

[ https://issues.apache.org/jira/browse/FLINK-13931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13931: Attachment: FLINK-13931.patch > Support Hive version 2.0.x > -- > >

[jira] [Updated] (FLINK-13931) Support Hive version 2.0.x

[ https://issues.apache.org/jira/browse/FLINK-13931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13931: Description: Including 2.0.0 and 2.0.1. (was: Including 3.1.0, 3.1.1, and 3.1.2.) > Support

[jira] [Created] (FLINK-13931) Support Hive version 2.0.x

Xuefu Zhang created FLINK-13931: --- Summary: Support Hive version 2.0.x Key: FLINK-13931 URL: https://issues.apache.org/jira/browse/FLINK-13931 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13930) Support Hive version 3.1.x

[ https://issues.apache.org/jira/browse/FLINK-13930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13930: Description: Including 3.1.0, 3.1.1, and 3.1.2. (was: Hive 2.3.6 is released a few days ago. We

[jira] [Created] (FLINK-13930) Support Hive version 3.1.x

Xuefu Zhang created FLINK-13930: --- Summary: Support Hive version 3.1.x Key: FLINK-13930 URL: https://issues.apache.org/jira/browse/FLINK-13930 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13903) Support Hive version 2.3.6

[ https://issues.apache.org/jira/browse/FLINK-13903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13903: Description: Hive 2.3.6 is released a few days ago. We can trivially support this version as

[jira] [Created] (FLINK-13903) Support Hive version 2.3.6

Xuefu Zhang created FLINK-13903: --- Summary: Support Hive version 2.3.6 Key: FLINK-13903 URL: https://issues.apache.org/jira/browse/FLINK-13903 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13877) Support Hive version 2.1.0 and 2.1.1

[ https://issues.apache.org/jira/browse/FLINK-13877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13877: Labels: (was: pull-request-available) > Support Hive version 2.1.0 and 2.1.1 >

[jira] [Updated] (FLINK-13877) Support Hive version 2.1.0 and 2.1.1

[ https://issues.apache.org/jira/browse/FLINK-13877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13877: Description: This is to support Hive 2.1 versions (2.1.0 and 2.1.1). (was: This is to support

[jira] [Created] (FLINK-13877) Support Hive version 2.1.0 and 2.1.1

Xuefu Zhang created FLINK-13877: --- Summary: Support Hive version 2.1.0 and 2.1.1 Key: FLINK-13877 URL: https://issues.apache.org/jira/browse/FLINK-13877 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13841) Extend Hive version support to all 1.2 and 2.3 versions

Xuefu Zhang created FLINK-13841: --- Summary: Extend Hive version support to all 1.2 and 2.3 versions Key: FLINK-13841 URL: https://issues.apache.org/jira/browse/FLINK-13841 Project: Flink Issue

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

[ https://issues.apache.org/jira/browse/FLINK-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909252#comment-16909252 ] Xuefu Zhang commented on FLINK-13741: - Re: Once FunctionCatalog has been integrated into the catalog

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

[ https://issues.apache.org/jira/browse/FLINK-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909226#comment-16909226 ] Xuefu Zhang commented on FLINK-13741: - Thanks all for the inputs. I think we are pretty much

[jira] [Commented] (FLINK-13643) Document the workaround for users with a different minor Hive version

[ https://issues.apache.org/jira/browse/FLINK-13643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16902246#comment-16902246 ] Xuefu Zhang commented on FLINK-13643: - cc: [~Terry1897] > Document the workaround for users with a

[jira] [Created] (FLINK-13643) Document the workaround for users with a different minor Hive version

Xuefu Zhang created FLINK-13643: --- Summary: Document the workaround for users with a different minor Hive version Key: FLINK-13643 URL: https://issues.apache.org/jira/browse/FLINK-13643 Project: Flink

[jira] [Created] (FLINK-13569) DDL table property key is defined as indentifier but should be string literal instead

Xuefu Zhang created FLINK-13569: --- Summary: DDL table property key is defined as indentifier but should be string literal instead Key: FLINK-13569 URL: https://issues.apache.org/jira/browse/FLINK-13569

[jira] [Created] (FLINK-13568) DDL create table doesn't allow STRING data type

Xuefu Zhang created FLINK-13568: --- Summary: DDL create table doesn't allow STRING data type Key: FLINK-13568 URL: https://issues.apache.org/jira/browse/FLINK-13568 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-13532) Broken links in documentation

[ https://issues.apache.org/jira/browse/FLINK-13532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16899075#comment-16899075 ] Xuefu Zhang edited comment on FLINK-13532 at 8/2/19 5:50 PM: - Sure. Will do.

[jira] [Commented] (FLINK-13532) Broken links in documentation

[ https://issues.apache.org/jira/browse/FLINK-13532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16899075#comment-16899075 ] Xuefu Zhang commented on FLINK-13532: - Sure. Will do. > Broken links in documentation >

[jira] [Commented] (FLINK-13532) Broken links in documentation

[ https://issues.apache.org/jira/browse/FLINK-13532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898209#comment-16898209 ] Xuefu Zhang commented on FLINK-13532: - cc [~sjwiesman] for visibility. > Broken links in

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

[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897757#comment-16897757 ] Xuefu Zhang commented on FLINK-13279: - [~dawidwys], I understand this is a conscious decision that

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

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897747#comment-16897747 ] Xuefu Zhang commented on FLINK-13501: - Yes. my screen shot is a little obsolete, so some of the

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

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897744#comment-16897744 ] Xuefu Zhang commented on FLINK-13501: - Hi [~lirui],OK, I will take a new look. Thanks. > Fixes a

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

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13501: Attachment: Screen Shot 2019-07-30 at 3.25.13 PM.png Screen Shot 2019-07-30 at

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

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896589#comment-16896589 ] Xuefu Zhang commented on FLINK-13501: - cc: [~tiwalter], [~Terry1897] > Fixes a few issues in

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

Xuefu Zhang created FLINK-13501: --- Summary: Fixes a few issues in documentation for Hive integration Key: FLINK-13501 URL: https://issues.apache.org/jira/browse/FLINK-13501 Project: Flink Issue

[jira] [Comment Edited] (FLINK-13438) Hive source/sink/udx should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895612#comment-16895612 ] Xuefu Zhang edited comment on FLINK-13438 at 7/29/19 9:53 PM: -- Hi

[jira] [Commented] (FLINK-13438) Hive source/sink/udx should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895612#comment-16895612 ] Xuefu Zhang commented on FLINK-13438: - Hi [~TsReaper], Thank you for reporting the issue and

[jira] [Updated] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13278: Priority: Major (was: Blocker) > add Chinese documentation for Hive source/sink >

[jira] [Commented] (FLINK-13443) Support/Map Hive INTERVAL type in Hive connector

[ https://issues.apache.org/jira/browse/FLINK-13443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894012#comment-16894012 ] Xuefu Zhang commented on FLINK-13443: - cc: [~Terry1897], [~twalthr], [~phoenixjiangnan] >

[jira] [Created] (FLINK-13443) Support/Map Hive INTERVAL type in Hive connector

Xuefu Zhang created FLINK-13443: --- Summary: Support/Map Hive INTERVAL type in Hive connector Key: FLINK-13443 URL: https://issues.apache.org/jira/browse/FLINK-13443 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13438: Priority: Blocker (was: Major) > Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support >

[jira] [Updated] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13278: Priority: Blocker (was: Major) > add Chinese documentation for Hive source/sink >

[jira] [Commented] (FLINK-13436) Add TPC-H queries as E2E tests

[ https://issues.apache.org/jira/browse/FLINK-13436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893934#comment-16893934 ] Xuefu Zhang commented on FLINK-13436: - Maybe we can use Hive data for this, which can verify both

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893932#comment-16893932 ] Xuefu Zhang commented on FLINK-13437: - There seems to be a JIRA (FLINK-13303) covering this. We are

[jira] [Commented] (FLINK-13385) Align Hive data type mapping with FLIP-37

[ https://issues.apache.org/jira/browse/FLINK-13385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891444#comment-16891444 ] Xuefu Zhang commented on FLINK-13385: - Hi [~twalthr], thanks for pointing this out. I'm not sure if

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

[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1664#comment-1664 ] Xuefu Zhang commented on FLINK-13279: - Thank [~twalthr] and [~dawidwys] for sharing the research

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

[ https://issues.apache.org/jira/browse/FLINK-13279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888197#comment-16888197 ] Xuefu Zhang commented on FLINK-13279: - [~dawidwys] thanks for looking into this. After thinking

[jira] [Commented] (FLINK-13265) Noisy hive-connector tests

[ https://issues.apache.org/jira/browse/FLINK-13265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885236#comment-16885236 ] Xuefu Zhang commented on FLINK-13265: - cc [~phoenixjiangnan]. We used to have a similar issue in

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883489#comment-16883489 ] Xuefu Zhang commented on FLINK-13150: - Hi [~zjffdu], tableEnv.registerDataSet() is meant to register

[jira] [Comment Edited] (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:comment-tabpanel=16883277#comment-16883277 ] Xuefu Zhang edited comment on FLINK-13206 at 7/11/19 7:29 PM: -- Actually no.

[jira] [Commented] (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:comment-tabpanel=16883277#comment-16883277 ] Xuefu Zhang commented on FLINK-13206: - Actually no. {{Catalog}} is the parent and so an aggregation

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882543#comment-16882543 ] Xuefu Zhang commented on FLINK-13150: - Further investigation shows that the two variables were

[jira] [Assigned] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang reassigned FLINK-13150: --- Assignee: Xuefu Zhang > defaultCatalogName and defaultDatabaseName in TableEnvImpl is not

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881416#comment-16881416 ] Xuefu Zhang commented on FLINK-13150: - After talking to [~twalthr] in person and it's clarified that

[jira] [Commented] (FLINK-13138) Make SqlCommandParser.SqlCommand as public

[ https://issues.apache.org/jira/browse/FLINK-13138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880616#comment-16880616 ] Xuefu Zhang commented on FLINK-13138: - [~zjffdu], it would be good if you can provide a use case for

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880615#comment-16880615 ] Xuefu Zhang commented on FLINK-13150: - [~zjffdu] good observation! I know there was a discussion of

[jira] [Commented] (FLINK-13152) Unable to run query when using HiveCatalog and DataSet api

[ https://issues.apache.org/jira/browse/FLINK-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880579#comment-16880579 ] Xuefu Zhang commented on FLINK-13152: - Yeah. I think we can close it. > Unable to run query when

[jira] [Closed] (FLINK-13152) Unable to run query when using HiveCatalog and DataSet api

[ https://issues.apache.org/jira/browse/FLINK-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang closed FLINK-13152. --- Resolution: Won't Fix > Unable to run query when using HiveCatalog and DataSet api >

[jira] [Created] (FLINK-13047) Fix the Optional.orElse() usage issue in DatabaseCalciteSchema

Xuefu Zhang created FLINK-13047: --- Summary: Fix the Optional.orElse() usage issue in DatabaseCalciteSchema Key: FLINK-13047 URL: https://issues.apache.org/jira/browse/FLINK-13047 Project: Flink

[jira] [Created] (FLINK-13023) Generate HiveTableSource from from a Hive table

Xuefu Zhang created FLINK-13023: --- Summary: Generate HiveTableSource from from a Hive table Key: FLINK-13023 URL: https://issues.apache.org/jira/browse/FLINK-13023 Project: Flink Issue Type:

[jira] [Updated] (FLINK-13023) Generate HiveTableSource from from a Hive table

[ https://issues.apache.org/jira/browse/FLINK-13023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13023: Description: As a followup for FLINK-11480, this adds the conversion from a Hive table to a table

[jira] [Updated] (FLINK-12989) Generate HiveTableSink from from a Hive table

[ https://issues.apache.org/jira/browse/FLINK-12989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-12989: Summary: Generate HiveTableSink from from a Hive table (was: Add implementation of converting

[jira] [Created] (FLINK-12989) Add implementation of converting Hive catalog table to Hive table sink

Xuefu Zhang created FLINK-12989: --- Summary: Add implementation of converting Hive catalog table to Hive table sink Key: FLINK-12989 URL: https://issues.apache.org/jira/browse/FLINK-12989 Project: Flink

[jira] [Comment Edited] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864356#comment-16864356 ] Xuefu Zhang edited comment on FLINK-12771 at 6/14/19 6:49 PM: -- Hi

[jira] [Commented] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864356#comment-16864356 ] Xuefu Zhang commented on FLINK-12771: - Hi [~dawidwys], Re: #2, communicating with Hive metastore

[jira] [Commented] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863503#comment-16863503 ] Xuefu Zhang commented on FLINK-12771: - > [~bdaw] commented on PR #8720: > I don't think this feature

[jira] [Created] (FLINK-12552) Combine HiveCatalog and GenericHiveMetastoreCatalog

Xuefu Zhang created FLINK-12552: --- Summary: Combine HiveCatalog and GenericHiveMetastoreCatalog Key: FLINK-12552 URL: https://issues.apache.org/jira/browse/FLINK-12552 Project: Flink Issue

[jira] [Created] (FLINK-12469) Clean up catalog API on default/current DB

Xuefu Zhang created FLINK-12469: --- Summary: Clean up catalog API on default/current DB Key: FLINK-12469 URL: https://issues.apache.org/jira/browse/FLINK-12469 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-12441) Add column stats for decimal type

[ https://issues.apache.org/jira/browse/FLINK-12441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang reassigned FLINK-12441: --- Assignee: (was: Xuefu Zhang) > Add column stats for decimal type >

[jira] [Created] (FLINK-12442) Add some more (negative) test cases for FLINK-12365

Xuefu Zhang created FLINK-12442: --- Summary: Add some more (negative) test cases for FLINK-12365 Key: FLINK-12442 URL: https://issues.apache.org/jira/browse/FLINK-12442 Project: Flink Issue

[jira] [Created] (FLINK-12441) Add column stats for decimal type

Xuefu Zhang created FLINK-12441: --- Summary: Add column stats for decimal type Key: FLINK-12441 URL: https://issues.apache.org/jira/browse/FLINK-12441 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-10758) Refactor TableEnvironment so that all registration calls delegate to CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang resolved FLINK-10758. - Resolution: Done The actual work is captured in FLINK-11476. Thus, I close this in favor of

[jira] [Resolved] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang resolved FLINK-10618. - Resolution: Done This JIRA seems to be a hive-level proposal, while most of the actual work is

[jira] [Created] (FLINK-12366) Clean up Catalog APIs to make them more consistent and coherent

Xuefu Zhang created FLINK-12366: --- Summary: Clean up Catalog APIs to make them more consistent and coherent Key: FLINK-12366 URL: https://issues.apache.org/jira/browse/FLINK-12366 Project: Flink

[jira] [Updated] (FLINK-12365) Add stats related catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-12365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-12365: Description: This is to support (table and column) stats for table/partition with related to

[jira] [Created] (FLINK-12365) Add stats related catalog APIs

Xuefu Zhang created FLINK-12365: --- Summary: Add stats related catalog APIs Key: FLINK-12365 URL: https://issues.apache.org/jira/browse/FLINK-12365 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12255) Rename a few exception class names that were migrated from scala

Xuefu Zhang created FLINK-12255: --- Summary: Rename a few exception class names that were migrated from scala Key: FLINK-12255 URL: https://issues.apache.org/jira/browse/FLINK-12255 Project: Flink

[jira] [Created] (FLINK-11519) Add function related catalog APIs

Xuefu Zhang created FLINK-11519: --- Summary: Add function related catalog APIs Key: FLINK-11519 URL: https://issues.apache.org/jira/browse/FLINK-11519 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11518) Add partition related catalog APIs

Xuefu Zhang created FLINK-11518: --- Summary: Add partition related catalog APIs Key: FLINK-11518 URL: https://issues.apache.org/jira/browse/FLINK-11518 Project: Flink Issue Type: Sub-task

[jira] [Issue Comment Deleted] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10618: Comment: was deleted (was: This task is superseded by FLINK-11482. ) > Introduce catalog for

[jira] [Commented] (FLINK-10697) Create FlinkInMemoryCatalog class, an in-memory catalog that stores Flink's meta objects for production use

[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756756#comment-16756756 ] Xuefu Zhang commented on FLINK-10697: - The task here is superseded by FLINK-11475. > Create

[jira] [Closed] (FLINK-10697) Create FlinkInMemoryCatalog class, an in-memory catalog that stores Flink's meta objects for production use

[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang closed FLINK-10697. --- Resolution: Duplicate Fix Version/s: (was: 1.8.0) > Create FlinkInMemoryCatalog class,

[jira] [Closed] (FLINK-10699) Create FlinkHmsCatalog for persistent Flink meta objects using Hive metastore as a registry

[ https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang closed FLINK-10699. --- Resolution: Duplicate This duplicates FLINK-11482. > Create FlinkHmsCatalog for persistent Flink

[jira] [Created] (FLINK-11482) Implement GenericHiveMetastoreCatalog

Xuefu Zhang created FLINK-11482: --- Summary: Implement GenericHiveMetastoreCatalog Key: FLINK-11482 URL: https://issues.apache.org/jira/browse/FLINK-11482 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756752#comment-16756752 ] Xuefu Zhang commented on FLINK-10618: - This task is superseded by FLINK-11482. > Introduce catalog

[jira] [Closed] (FLINK-10542) Implement an external catalog for Hive

[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang closed FLINK-10542. --- Resolution: Duplicate > Implement an external catalog for Hive >

[jira] [Commented] (FLINK-10542) Implement an external catalog for Hive

[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756748#comment-16756748 ] Xuefu Zhang commented on FLINK-10542: - The task here is superseded by FLINK-11479. > Implement an

[jira] [Created] (FLINK-11481) Integrate HiveTableFactory with existing table factory discovery mechanism

Xuefu Zhang created FLINK-11481: --- Summary: Integrate HiveTableFactory with existing table factory discovery mechanism Key: FLINK-11481 URL: https://issues.apache.org/jira/browse/FLINK-11481 Project:

[jira] [Created] (FLINK-11480) Create HiveTableFactory that creates TableSource/Sink from a Hive table

Xuefu Zhang created FLINK-11480: --- Summary: Create HiveTableFactory that creates TableSource/Sink from a Hive table Key: FLINK-11480 URL: https://issues.apache.org/jira/browse/FLINK-11480 Project: Flink

[jira] [Updated] (FLINK-11275) Unified Catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-11275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-11275: Description: During Flink-Hive integration, we found that the current Catalog APIs are quite

[jira] [Created] (FLINK-11479) Implement HiveCatalog

Xuefu Zhang created FLINK-11479: --- Summary: Implement HiveCatalog Key: FLINK-11479 URL: https://issues.apache.org/jira/browse/FLINK-11479 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11477) Define catalog entries in SQL client YAML file and handle the creation and registration of those entries

Xuefu Zhang created FLINK-11477: --- Summary: Define catalog entries in SQL client YAML file and handle the creation and registration of those entries Key: FLINK-11477 URL:

[jira] [Created] (FLINK-11478) Handle existing table registration via YAML file in the context of catalog support

Xuefu Zhang created FLINK-11478: --- Summary: Handle existing table registration via YAML file in the context of catalog support Key: FLINK-11478 URL: https://issues.apache.org/jira/browse/FLINK-11478

[jira] [Created] (FLINK-11476) Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema

Xuefu Zhang created FLINK-11476: --- Summary: Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema Key: FLINK-11476 URL: https://issues.apache.org/jira/browse/FLINK-11476

[jira] [Created] (FLINK-11475) Adapt existing InMemoryExternalCatalog to GenericInMemoryCatalog

Xuefu Zhang created FLINK-11475: --- Summary: Adapt existing InMemoryExternalCatalog to GenericInMemoryCatalog Key: FLINK-11475 URL: https://issues.apache.org/jira/browse/FLINK-11475 Project: Flink

[jira] [Created] (FLINK-11474) Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces

Xuefu Zhang created FLINK-11474: --- Summary: Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces Key: FLINK-11474 URL: https://issues.apache.org/jira/browse/FLINK-11474 Project:

[jira] [Created] (FLINK-11275) Unified Catalog APIs

Xuefu Zhang created FLINK-11275: --- Summary: Unified Catalog APIs Key: FLINK-11275 URL: https://issues.apache.org/jira/browse/FLINK-11275 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680324#comment-16680324 ] Xuefu Zhang commented on FLINK-6574: I understand this is an old JIRA, but going retrospective, I

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676117#comment-16676117 ] Xuefu Zhang commented on FLINK-9172: Hi [~walterddr], thanks for chiming in. I don't think we are

  1   2   >