[jira] [Assigned] (FLINK-14659) add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql parser

[ https://issues.apache.org/jira/browse/FLINK-14659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-14659: Assignee: (was: Bowen Li) > add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql parser

[jira] [Closed] (FLINK-15453) Remove unneeded HiveShim methods

[ https://issues.apache.org/jira/browse/FLINK-15453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15453. Fix Version/s: 1.11.0 1.10.0 Assignee: Rui Li Resolution: Fixed master:

[jira] [Updated] (FLINK-15468) INSERT OVERWRITE not supported from SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15468: - Affects Version/s: 1.10.0 > INSERT OVERWRITE not supported from SQL CLI > --

[jira] [Closed] (FLINK-15468) INSERT OVERWRITE not supported from SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15468. Fix Version/s: 1.11.0 Resolution: Fixed master: 0a2cc58af87a0154160322d0669fcb22c736bde2 1.10: 80cf

[jira] [Updated] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15259: - Fix Version/s: 1.9.2 > HiveInspector.toInspectors() should convert Flink constant to Hive constant > --

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008439#comment-17008439 ] Bowen Li commented on FLINK-15259: -- 1.9: bcf540016fadf0e1bed708467ddeb0ae30c0a18a > Hi

[jira] [Closed] (FLINK-15429) HiveObjectConversion implementations need to handle null values

[ https://issues.apache.org/jira/browse/FLINK-15429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15429. Fix Version/s: 1.11.0 Resolution: Fixed master: 1c5806ae443626ce80f2de3bb85100abe9ba8e0c 1.10: 386d

[jira] [Closed] (FLINK-14980) add documentation and example for function DDL

[ https://issues.apache.org/jira/browse/FLINK-14980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14980. Resolution: Fixed master: cac6b9d39674b3e9de03cd5bd85df777fabb871b 1.10: c1099c1a3a5e14baa2db89530ac1bcb78

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006586#comment-17006586 ] Bowen Li commented on FLINK-15259: -- [~lirui] there's conflict when merging in 1.9. if w

[jira] [Closed] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15259. Fix Version/s: (was: 1.9.2) Resolution: Fixed master: 6f3a0778ba352e76c96160c3125e4e0ee88addba

[jira] [Closed] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15290. Fix Version/s: 1.11.0 Resolution: Fixed master: f205d754ad513a8e16dd2b9d5fa4586149ac7013 1.10: 694a

[jira] [Commented] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004342#comment-17004342 ] Bowen Li commented on FLINK-15411: -- yes, date is probably the most popular partition ty

[jira] [Updated] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15411: - Fix Version/s: 1.11.0 > Planner can't prune partition on DATE/TIMESTAMP columns > --

[jira] [Closed] (FLINK-14849) Fix documentation about Hive dependencies

[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14849. Fix Version/s: 1.11.0 Resolution: Fixed master: 28b6221aaaeb535afa728bb887e733b6576982a7 1.10: 7ada

[jira] [Closed] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15412. Resolution: Fixed release-1.9: baeb9b38bfef4b39f12bc7fe3934e140b3926698 > LocalExecutorITCase#testParamet

[jira] [Closed] (FLINK-15189) Add documentation for hive view

[ https://issues.apache.org/jira/browse/FLINK-15189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15189. Fix Version/s: 1.11.0 Resolution: Fixed master: 2e0ba5d92750ab21273f8dc15ae7051c431f4eb7 1.10: a87b

[jira] [Created] (FLINK-15411) HiveCatalog can't prune partition on DATE/TIMESTAMP columns

Bowen Li created FLINK-15411: Summary: HiveCatalog can't prune partition on DATE/TIMESTAMP columns Key: FLINK-15411 URL: https://issues.apache.org/jira/browse/FLINK-15411 Project: Flink Issue Ty

[jira] [Closed] (FLINK-15391) DATE and TIMESTAMP partition columns don't work

[ https://issues.apache.org/jira/browse/FLINK-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15391. Fix Version/s: 1.11.0 Resolution: Fixed master: 2e9a7f38fa9971958ed3e02cdaa45528e5e657d4 1.10: 694c

[jira] [Closed] (FLINK-15342) Verify querying Hive view

[ https://issues.apache.org/jira/browse/FLINK-15342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15342. Fix Version/s: 1.11.0 Assignee: Rui Li Resolution: Fixed master: b3ff6ae073e9a5a33ce4487be

[jira] [Updated] (FLINK-15206) support dynamic catalog table for truly unified SQL job

[ https://issues.apache.org/jira/browse/FLINK-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15206: - Description: currently if users have both an online and an offline job with same business logic in Flin

[jira] [Created] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

Bowen Li created FLINK-15376: Summary: support "CREATE TABLE AS" in Flink SQL Key: FLINK-15376 URL: https://issues.apache.org/jira/browse/FLINK-15376 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-15344) Update limitations in hive udf document

[ https://issues.apache.org/jira/browse/FLINK-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15344. Fix Version/s: 1.11.0 Resolution: Fixed master: 5ec3feac0ecf4991faf1ba9e6d45125ae8536e75 1.10: 3245

[jira] [Commented] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002489#comment-17002489 ] Bowen Li commented on FLINK-15262: -- I used 1 field to simplify the repro, they should b

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15262: - Description: I created a kafka table in Flink to read from my kakfa topic (already has messages in it)

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15262: - Priority: Major (was: Critical) > kafka connector doesn't read from beginning immediately when > 'conn

[jira] [Closed] (FLINK-15348) Fix orc optimization for version less than 2.3 by introducing orc shim

[ https://issues.apache.org/jira/browse/FLINK-15348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15348. Resolution: Fixed master: 790a07787e3dd6f5795b4fb5cb84df953363d64a 1.10: 37fbbd4ba57d356b1877a9b7d60025455

[jira] [Assigned] (FLINK-15361) ParquetTableSource should pass predicate in projectFields

[ https://issues.apache.org/jira/browse/FLINK-15361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15361: Assignee: Jingsong Lee > ParquetTableSource should pass predicate in projectFields >

[jira] [Closed] (FLINK-15361) ParquetTableSource should pass predicate in projectFields

[ https://issues.apache.org/jira/browse/FLINK-15361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15361. Resolution: Fixed master: 0f88c392b6ad6f91aed33e157bdc9df6f613f09d 1.10: 627a47289c350d6ef0e6cd00cf62f021f

[jira] [Updated] (FLINK-15361) ParquetTableSource should pass predicate in projectFields

[ https://issues.apache.org/jira/browse/FLINK-15361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15361: - Fix Version/s: 1.11.0 > ParquetTableSource should pass predicate in projectFields >

[jira] [Updated] (FLINK-15351) develop PostgresJDBCCatalog to connect Flink with Postgres tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15351: - Summary: develop PostgresJDBCCatalog to connect Flink with Postgres tables and ecosystem (was: develop

[jira] [Updated] (FLINK-15352) develop MySQLJDBCCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15352: - Summary: develop MySQLJDBCCatalog to connect Flink with MySQL tables and ecosystem (was: develop MySQL

[jira] [Created] (FLINK-15353) develop AbstractJDBCCatalog

Bowen Li created FLINK-15353: Summary: develop AbstractJDBCCatalog Key: FLINK-15353 URL: https://issues.apache.org/jira/browse/FLINK-15353 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-15351) develop PostgresJDBCCatalog

Bowen Li created FLINK-15351: Summary: develop PostgresJDBCCatalog Key: FLINK-15351 URL: https://issues.apache.org/jira/browse/FLINK-15351 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-15352) develop MySQLJDBCCatalog

Bowen Li created FLINK-15352: Summary: develop MySQLJDBCCatalog Key: FLINK-15352 URL: https://issues.apache.org/jira/browse/FLINK-15352 Project: Flink Issue Type: Sub-task Components: C

[jira] [Updated] (FLINK-15206) support dynamic catalog table for truly unified SQL job

[ https://issues.apache.org/jira/browse/FLINK-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15206: - Fix Version/s: (was: 1.11.0) > support dynamic catalog table for truly unified SQL job > ---

[jira] [Updated] (FLINK-15350) develop JDBC catalogs to connect to relational databases

[ https://issues.apache.org/jira/browse/FLINK-15350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15350: - Fix Version/s: (was: 1.11.0) > develop JDBC catalogs to connect to relational databases > --

[jira] [Updated] (FLINK-15350) develop JDBC catalogs to connect to relational databases

[ https://issues.apache.org/jira/browse/FLINK-15350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15350: - Summary: develop JDBC catalogs to connect to relational databases (was: develop JDBCCatalog to connect

[jira] [Created] (FLINK-15350) develop JDBCCatalog to connect to relational databases

Bowen Li created FLINK-15350: Summary: develop JDBCCatalog to connect to relational databases Key: FLINK-15350 URL: https://issues.apache.org/jira/browse/FLINK-15350 Project: Flink Issue Type: Ne

[jira] [Updated] (FLINK-15206) support dynamic catalog table for truly unified SQL job

[ https://issues.apache.org/jira/browse/FLINK-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15206: - Description: currently if users have both an online and an offline job with same business logic in Flin

[jira] [Updated] (FLINK-15206) support dynamic catalog table for truly unified SQL job

[ https://issues.apache.org/jira/browse/FLINK-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15206: - Description: currently if users have both an online and an offline job with same business logic in Flin

[jira] [Updated] (FLINK-15349) add Catalog DDL support in FLIP-69

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15349: - Description: https://cwiki.apache.org/confluence/display/FLINK/FLIP+69+-+Flink+SQL+DDL+Enhancement some

[jira] [Created] (FLINK-15349) add Catalog DDL support in FLIP-69

Bowen Li created FLINK-15349: Summary: add Catalog DDL support in FLIP-69 Key: FLINK-15349 URL: https://issues.apache.org/jira/browse/FLINK-15349 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-14796) Add document about limitations of different Hive versions

[ https://issues.apache.org/jira/browse/FLINK-14796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14796. Assignee: Bowen Li (was: Rui Li) Resolution: Fixed master: 0468708fb951dd2589e30b78c9632deb60d0b56a

[jira] [Updated] (FLINK-14796) Add document about limitations of different Hive versions

[ https://issues.apache.org/jira/browse/FLINK-14796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14796: - Fix Version/s: 1.11.0 > Add document about limitations of different Hive versions >

[jira] [Closed] (FLINK-15322) Parquet test fails with Hive versions prior to 1.2.0

[ https://issues.apache.org/jira/browse/FLINK-15322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15322. Resolution: Fixed master: c84f20692592c529247b2e8faef4f62ed7d5bf05 1.10: f06fd92c29b16a1ea1eccfd0645115cd7

[jira] [Updated] (FLINK-15322) Parquet test fails with Hive versions prior to 1.2.0

[ https://issues.apache.org/jira/browse/FLINK-15322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15322: - Fix Version/s: 1.11.0 > Parquet test fails with Hive versions prior to 1.2.0 > -

[jira] [Assigned] (FLINK-15322) Parquet test fails with Hive versions prior to 1.2.0

[ https://issues.apache.org/jira/browse/FLINK-15322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15322: Assignee: Rui Li > Parquet test fails with Hive versions prior to 1.2.0 > ---

[jira] [Updated] (FLINK-15287) ack flink-hadoop-compatibility and flink-orc into flink-hive

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15287: - Description: flink-connector-hive should contain flink-hadoop-compatibility to reduce users' efforts in

[jira] [Created] (FLINK-15348) Fix orc optimization for version less than 2.3 by introducing orc shim

Bowen Li created FLINK-15348: Summary: Fix orc optimization for version less than 2.3 by introducing orc shim Key: FLINK-15348 URL: https://issues.apache.org/jira/browse/FLINK-15348 Project: Flink

[jira] [Updated] (FLINK-15287) ack flink-hadoop-compatibility and flink-orc into flink-hive

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15287: - Summary: ack flink-hadoop-compatibility and flink-orc into flink-hive (was: Vectorized orc reader fails

[jira] [Closed] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15287. Resolution: Fixed master: 57be6edb7da0e32a9e4a35172e2d5ed56065a6df 1.10: 9026a5ae35d566f8bf755a3e053fffb4f

[jira] [Updated] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15259: - Priority: Blocker (was: Major) > HiveInspector.toInspectors() should convert Flink constant to Hive con

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000621#comment-17000621 ] Bowen Li commented on FLINK-15259: -- [~lirui] glad you added profile picture. It helps!

[jira] [Assigned] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15259: Assignee: Rui Li (was: Rui Li) > HiveInspector.toInspectors() should convert Flink constant to H

[jira] [Commented] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000615#comment-17000615 ] Bowen Li commented on FLINK-15262: -- [~becket_qin] I added some steps > kafka connector

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15262: - Description: I created a kafka table in Flink to read from my kakfa topic (already has messages in it)

[jira] [Commented] (FLINK-15258) HiveModuleFactory should be able to distinguish hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999762#comment-16999762 ] Bowen Li commented on FLINK-15258: -- [~trohrmann] I thought the original title was prett

[jira] [Updated] (FLINK-15258) HiveModuleFactory should be able to distinguish hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15258: - Description: HiveModuleFactory should be able to distinguish hive-version as supported property. it curr

[jira] [Updated] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15258: - Description: HiveModuleFactory should be able to distinguish hive-version as supported property (was: H

[jira] [Updated] (FLINK-15258) HiveModuleFactory should be able to distinguish hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15258: - Summary: HiveModuleFactory should be able to distinguish hive-version as property (was: HiveModuleFacto

[jira] [Closed] (FLINK-15256) unable to drop table in HiveCatalogITCase

[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15256. Resolution: Invalid > unable to drop table in HiveCatalogITCase >

[jira] [Commented] (FLINK-15256) unable to drop table in HiveCatalogITCase

[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999470#comment-16999470 ] Bowen Li commented on FLINK-15256: -- [~Terry1897] I ran it today and it succeeded, maybe

[jira] [Updated] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15287: - Fix Version/s: 1.11.0 > Vectorized orc reader fails with Hive 2.0.1 > --

[jira] [Commented] (FLINK-15234) hive table created from flink catalog table shouldn't have null properties in parameters

[ https://issues.apache.org/jira/browse/FLINK-15234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998736#comment-16998736 ] Bowen Li commented on FLINK-15234: -- 1.9: cca2387a48e42950f0e53f8d9f002a4e0acf0c94 > hi

[jira] [Updated] (FLINK-15240) is_generic key is missing for Flink table stored in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15240: - Fix Version/s: 1.9.2 > is_generic key is missing for Flink table stored in HiveCatalog > ---

[jira] [Commented] (FLINK-15240) is_generic key is missing for Flink table stored in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998735#comment-16998735 ] Bowen Li commented on FLINK-15240: -- 1.9.2: 4e07b8c371a9130a9316ff9d4a731caac06c8df9 >

[jira] [Updated] (FLINK-15234) hive table created from flink catalog table shouldn't have null properties in parameters

[ https://issues.apache.org/jira/browse/FLINK-15234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15234: - Fix Version/s: 1.9.2 > hive table created from flink catalog table shouldn't have null properties in >

[jira] [Created] (FLINK-15303) support predicate pushdown for sources in hive connector

Bowen Li created FLINK-15303: Summary: support predicate pushdown for sources in hive connector Key: FLINK-15303 URL: https://issues.apache.org/jira/browse/FLINK-15303 Project: Flink Issue Type:

[jira] [Updated] (FLINK-15302) properties in create table DDL need to be backward compatible

[ https://issues.apache.org/jira/browse/FLINK-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15302: - Description: since we have a persistent HiveCatalog now, properties in create table DDL need to be back

[jira] [Created] (FLINK-15302) properties in create table DDL need to be backward compatible

Bowen Li created FLINK-15302: Summary: properties in create table DDL need to be backward compatible Key: FLINK-15302 URL: https://issues.apache.org/jira/browse/FLINK-15302 Project: Flink Issue

[jira] [Updated] (FLINK-14980) add documentation and example for function DDL

[ https://issues.apache.org/jira/browse/FLINK-14980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14980: - Fix Version/s: 1.11.0 > add documentation and example for function DDL > ---

[jira] [Updated] (FLINK-14980) add documentation and example for function DDL

[ https://issues.apache.org/jira/browse/FLINK-14980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14980: - Priority: Blocker (was: Major) > add documentation and example for function DDL > -

[jira] [Assigned] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15205: Assignee: Jingsong Lee (was: Rui Li) > add doc and exmaple of INSERT OVERWRITE and insert into p

[jira] [Closed] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15205. Resolution: Fixed master: 1384381bb9ef65b195ed40434dcced68c7069624 1.10: 58eb541dd9cdf48aefe7ef2862915b06e

[jira] [Updated] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15205: - Fix Version/s: 1.11.0 > add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for >

[jira] [Closed] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15258. Resolution: Fixed master: 4e3b8cc3142da9694add4893d2713e43fa596a09 1.10： aeb00ab478d5d518bec6722378ae05e96

[jira] [Commented] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998511#comment-16998511 ] Bowen Li commented on FLINK-15258: -- [~trohrmann] the current behavior is different that

[jira] [Comment Edited] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998511#comment-16998511 ] Bowen Li edited comment on FLINK-15258 at 12/17/19 7:32 PM:

[jira] [Updated] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15258: - Summary: HiveModuleFactory should take hive-version as property (was: HiveModuleFactory should take hiv

[jira] [Closed] (FLINK-15148) Add doc for create/drop/alter database ddl

[ https://issues.apache.org/jira/browse/FLINK-15148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15148. Resolution: Duplicate > Add doc for create/drop/alter database ddl > -

[jira] [Closed] (FLINK-15147) Add doc for alter table set properties and rename table ddl

[ https://issues.apache.org/jira/browse/FLINK-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15147. Resolution: Duplicate > Add doc for alter table set properties and rename table ddl >

[jira] [Closed] (FLINK-15254) modules in SQL CLI yaml should preserve order

[ https://issues.apache.org/jira/browse/FLINK-15254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15254. Resolution: Fixed master: 6a0570d6cd2e6da5159bec7e3a59144e91503ea9 1.10: 6dd510e6efb372f89f4b6c7cf82064d4f

[jira] [Closed] (FLINK-15263) add dedicated page for HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15263. Resolution: Fixed master: bd15e362559b9e935207f70727185e41117651a2 1.10: 1d41caee1a2cb4ade9039a66bf9bb2731

[jira] [Updated] (FLINK-15263) add dedicated page for HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15263: - Fix Version/s: (was: 1.9.2) > add dedicated page for HiveCatalog > -

[jira] [Closed] (FLINK-15128) Document support for Hive timestamp type

[ https://issues.apache.org/jira/browse/FLINK-15128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15128. Resolution: Fixed master: 7f8bd7159afdbd636e543daa78a918a29514f2e9 1.10: 3f65a3fe48970d338ca79a2f0ee7125f4

[jira] [Updated] (FLINK-15128) Document support for Hive timestamp type

[ https://issues.apache.org/jira/browse/FLINK-15128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15128: - Fix Version/s: 1.11.0 > Document support for Hive timestamp type > -

[jira] [Closed] (FLINK-15257) convert HiveCatalogITCase.testCsvTableViaAPI() to use blink planner

[ https://issues.apache.org/jira/browse/FLINK-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15257. Resolution: Fixed master: 2ba2a912b92197d895adb2e4bffd3f1e796bf283 1.10: 154e934e6c4e7bd32017b63d5b8177b80

[jira] [Closed] (FLINK-15190) add documentation for DDL in FLIP-69

[ https://issues.apache.org/jira/browse/FLINK-15190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15190. Fix Version/s: 1.11.0 Resolution: Fixed master: 10936d768f533909fcf0683e7ee3a7085958971b 1.10: b5b3

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16996970#comment-16996970 ] Bowen Li commented on FLINK-15259: -- This bug is only effecting functions that take char

[jira] [Updated] (FLINK-15015) add documentation for using HiveVectorizedOrcSplitReader in hive connector

[ https://issues.apache.org/jira/browse/FLINK-15015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15015: - Summary: add documentation for using HiveVectorizedOrcSplitReader in hive connector (was: add documenta

[jira] [Commented] (FLINK-15233) Improve Kafka connector properties make append update-mode as default

[ https://issues.apache.org/jira/browse/FLINK-15233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16996860#comment-16996860 ] Bowen Li commented on FLINK-15233: -- [~jark] can you find someone to fix it in 1.10? It'

[jira] [Created] (FLINK-15263) add dedicated page for HiveCatalog

Bowen Li created FLINK-15263: Summary: add dedicated page for HiveCatalog Key: FLINK-15263 URL: https://issues.apache.org/jira/browse/FLINK-15263 Project: Flink Issue Type: Task Compone

[jira] [Created] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

Bowen Li created FLINK-15262: Summary: kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset' Key: FLINK-15262 URL: https://issues.apache.org/jira/browse/FLINK-15262

[jira] [Created] (FLINK-15261) add dedicated documentation for blink planner

Bowen Li created FLINK-15261: Summary: add dedicated documentation for blink planner Key: FLINK-15261 URL: https://issues.apache.org/jira/browse/FLINK-15261 Project: Flink Issue Type: Task

[jira] [Closed] (FLINK-15255) document how to create Hive table from java API and DDL

[ https://issues.apache.org/jira/browse/FLINK-15255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15255. Resolution: Invalid we can't create hive tables yet > document how to create Hive table from java API and

[jira] [Updated] (FLINK-15255) document how to create Hive table from java API and DDL

[ https://issues.apache.org/jira/browse/FLINK-15255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15255: - Priority: Major (was: Blocker) > document how to create Hive table from java API and DDL >

[jira] [Closed] (FLINK-15234) hive table created from flink catalog table shouldn't have null properties in parameters

[ https://issues.apache.org/jira/browse/FLINK-15234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15234. Resolution: Fixed master: 940bdfc41a2d78ba972541c537925d102ccdc87f 1.10: b6373cba04a9f45d6a851684f80785a

[jira] [Closed] (FLINK-15240) is_generic key is missing for Flink table stored in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15240. Resolution: Fixed master: e4cecef07e73dcb7a2990b075b8fc12eaa02845f 1.10: fc0a19d2a12c3454759ad621093cfa3cd

[jira] [Updated] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15259: - Fix Version/s: 1.9.2 > HiveInspector.toInspectors() should convert Flink constant to Hive constant > --

[jira] [Updated] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15259: - Affects Version/s: 1.10.0 > HiveInspector.toInspectors() should convert Flink constant to Hive constant

<    1   2   3   4   5   6   7   8   9   10   >