[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051574#comment-17051574 ] Bowen Li commented on FLINK-11143: -- I tried on 1.10 and 1.11, and can confirm the issue

[jira] [Updated] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-11143: - Affects Version/s: 1.10.0 > AskTimeoutException is thrown during job submission and completion > ---

[jira] [Updated] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-11143: - Priority: Critical (was: Major) > AskTimeoutException is thrown during job submission and completion >

[jira] [Closed] (FLINK-15349) add "create catalog" DDL to blink planner

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15349. Release Note: added "CREATE CATALOG" DDL to blink planner to support dynamically loading catalogs Re

[jira] [Updated] (FLINK-15349) add "create catalog" DDL to blink planner

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15349: - Summary: add "create catalog" DDL to blink planner (was: add "create catalog" DDL) > add "create catal

[jira] [Closed] (FLINK-16055) Avoid catalog functions when listing Hive built-in functions

[ https://issues.apache.org/jira/browse/FLINK-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-16055. Resolution: Fixed > Avoid catalog functions when listing Hive built-in functions > ---

[jira] [Assigned] (FLINK-16055) Avoid catalog functions when listing Hive built-in functions

[ https://issues.apache.org/jira/browse/FLINK-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-16055: Assignee: Rui Li > Avoid catalog functions when listing Hive built-in functions > ---

[jira] [Updated] (FLINK-15349) add "create catalog" DDL

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15349: - Summary: add "create catalog" DDL (was: add "create catalog" DDL support) > add "create catalog" DDL >

[jira] [Updated] (FLINK-15349) add "create catalog" DDL support

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15349: - Summary: add "create catalog" DDL support (was: add "create catalog DDL support in FLIP-69) > add "cre

[jira] [Updated] (FLINK-15349) add "create 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: - Summary: add "create catalog DDL support in FLIP-69 (was: add Catalog DDL support in FLIP-69) > add "c

[jira] [Assigned] (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 reassigned FLINK-15349: Assignee: Bowen Li (was: Kurt Young) > add Catalog DDL support in FLIP-69 >

[jira] [Commented] (FLINK-16115) Aliyun oss filesystem could not work with plugin mechanism

[ https://issues.apache.org/jira/browse/FLINK-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038534#comment-17038534 ] Bowen Li commented on FLINK-16115: -- [~fly_in_gis] can you help find OSS people to fix t

[jira] [Updated] (FLINK-16115) Aliyun oss filesystem could not work with plugin mechanism

[ https://issues.apache.org/jira/browse/FLINK-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16115: - Priority: Critical (was: Major) > Aliyun oss filesystem could not work with plugin mechanism >

[jira] [Created] (FLINK-16107) github link on statefun.io should point to https://github.com/apache/flink-statefun

Bowen Li created FLINK-16107: Summary: github link on statefun.io should point to https://github.com/apache/flink-statefun Key: FLINK-16107 URL: https://issues.apache.org/jira/browse/FLINK-16107 Project:

[jira] [Closed] (FLINK-14802) Multi vectorized read version support for hive orc read

[ https://issues.apache.org/jira/browse/FLINK-14802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14802. Release Note: Support vectorized read for Hive 1.x versions. Resolution: Fixed master: 63e9e9d200ef4

[jira] [Updated] (FLINK-14802) Multi vectorized read version support for hive orc read

[ https://issues.apache.org/jira/browse/FLINK-14802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14802: - Release Note: Support vectorized read of ORC in Hive 1.x versions. (was: Support vectorized read for Hi

[jira] [Commented] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035919#comment-17035919 ] Bowen Li commented on FLINK-16023: -- [~jark]  The fundamental reason is that such a desi

[jira] [Created] (FLINK-16028) hbase connector's 'connector.table-name' property should be optional rather than required

Bowen Li created FLINK-16028: Summary: hbase connector's 'connector.table-name' property should be optional rather than required Key: FLINK-16028 URL: https://issues.apache.org/jira/browse/FLINK-16028 Pro

[jira] [Created] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

Bowen Li created FLINK-16027: Summary: kafka connector's 'connector.topic' property should be optional rather than required Key: FLINK-16027 URL: https://issues.apache.org/jira/browse/FLINK-16027 Project:

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16023: - Description: jdbc connector's 'connector.table' property should be optional rather than required. conn

[jira] [Created] (FLINK-16024) support filter pushdown in jdbc connector

Bowen Li created FLINK-16024: Summary: support filter pushdown in jdbc connector Key: FLINK-16024 URL: https://issues.apache.org/jira/browse/FLINK-16024 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

Bowen Li created FLINK-16023: Summary: jdbc connector's 'connector.table' property should be optional rather than required Key: FLINK-16023 URL: https://issues.apache.org/jira/browse/FLINK-16023 Project:

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16023: - Description: jdbc connector's 'connector.table' property should be optional rather than required. conn

[jira] [Closed] (FLINK-15933) update content of how generic table schema is stored in hive via HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15933. Fix Version/s: 1.10.0 Resolution: Fixed 1.10: 220fc5b6c04ac3c4d9a59b33177092136b9006b1 > update co

[jira] [Created] (FLINK-15986) support setting or changing session properties in Flink SQL

Bowen Li created FLINK-15986: Summary: support setting or changing session properties in Flink SQL Key: FLINK-15986 URL: https://issues.apache.org/jira/browse/FLINK-15986 Project: Flink Issue Ty

[jira] [Assigned] (FLINK-12256) Implement Confluent Schema Registry Catalog

[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-12256: Assignee: Bowen Li (was: Artsem Semianenka) > Implement Confluent Schema Registry Catalog >

[jira] [Created] (FLINK-15985) offload runtime params from DDL to table hints in DML/queries

Bowen Li created FLINK-15985: Summary: offload runtime params from DDL to table hints in DML/queries Key: FLINK-15985 URL: https://issues.apache.org/jira/browse/FLINK-15985 Project: Flink Issue

[jira] [Created] (FLINK-15984) support hive stream table sink

Bowen Li created FLINK-15984: Summary: support hive stream table sink Key: FLINK-15984 URL: https://issues.apache.org/jira/browse/FLINK-15984 Project: Flink Issue Type: New Feature Comp

[jira] [Updated] (FLINK-12814) Support a traditional and scrolling view of result (non-interactive)

[ https://issues.apache.org/jira/browse/FLINK-12814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12814: - Fix Version/s: 1.11.0 > Support a traditional and scrolling view of result (non-interactive) > -

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

[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14148: - Fix Version/s: 1.11.0 > Investigate pushing predicate/projection to underlying Hive input format > -

[jira] [Updated] (FLINK-15983) add native reader for Hive parquet files

[ https://issues.apache.org/jira/browse/FLINK-15983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15983: - Description: add native reader for Hive parquet files, as well as benchmark that show how faster the na

[jira] [Created] (FLINK-15983) add native reader for Hive parquet files

Bowen Li created FLINK-15983: Summary: add native reader for Hive parquet files Key: FLINK-15983 URL: https://issues.apache.org/jira/browse/FLINK-15983 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-15960) support creating Hive tables, views, functions within Flink

Bowen Li created FLINK-15960: Summary: support creating Hive tables, views, functions within Flink Key: FLINK-15960 URL: https://issues.apache.org/jira/browse/FLINK-15960 Project: Flink Issue Ty

[jira] [Assigned] (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 reassigned FLINK-15255: Assignee: Jingsong Lee (was: Bowen Li) > document how to create Hive table from java API and DDL

[jira] [Reopened] (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 reopened FLINK-15255: -- > document how to create Hive table from java API and DDL > --

[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: - Description: documentation Jira for  FLINK-15960 > document how to create Hive table from java API and D

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031280#comment-17031280 ] Bowen Li commented on FLINK-15858: -- [~lirui] [~lzljs3620320] please go over Flink docs

[jira] [Created] (FLINK-15933) update content of how generic table schema is stored in hive via HiveCatalog

Bowen Li created FLINK-15933: Summary: update content of how generic table schema is stored in hive via HiveCatalog Key: FLINK-15933 URL: https://issues.apache.org/jira/browse/FLINK-15933 Project: Flink

[jira] [Comment Edited] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030341#comment-17030341 ] Bowen Li edited comment on FLINK-15858 at 2/5/20 4:12 AM: -- I'm

[jira] [Comment Edited] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030341#comment-17030341 ] Bowen Li edited comment on FLINK-15858 at 2/5/20 4:12 AM: -- I'm

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030341#comment-17030341 ] Bowen Li commented on FLINK-15858: -- I'm ok with the proposed solution. However, that m

[jira] [Updated] (FLINK-15826) Add renameFunction() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15826: - Description: The {{Catalog}} interface lacks a method to rename a function. It is possible to change al

[jira] [Commented] (FLINK-15826) Add renameFunction() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027643#comment-17027643 ] Bowen Li commented on FLINK-15826: -- +1 > Add renameFunction() to Catalog > ---

[jira] [Commented] (FLINK-15825) Add renameDatabase() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027642#comment-17027642 ] Bowen Li commented on FLINK-15825: -- +1. Implementations can decide if they support this

[jira] [Commented] (FLINK-15809) component stack page needs to be updated for blink planner

[ https://issues.apache.org/jira/browse/FLINK-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17026426#comment-17026426 ] Bowen Li commented on FLINK-15809: -- [~sjwiesman] Why dropping it?   I think the page

[jira] [Created] (FLINK-15809) component stack page needs to be updated for blink planner

Bowen Li created FLINK-15809: Summary: component stack page needs to be updated for blink planner Key: FLINK-15809 URL: https://issues.apache.org/jira/browse/FLINK-15809 Project: Flink Issue Type

[jira] [Closed] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15592. Resolution: Fixed 1.10: 6afd2874aa0ab2578692fb0e71ab0a5c2137ff82 > Streaming sql throw hive exception whe

[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: - Description: introduce JDBCCatalog and a set of JDBC catalog implementations to connect Flink to all re

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17019229#comment-17019229 ] Bowen Li commented on FLINK-15350: -- would be both [~1026688210] > develop JDBC catalog

[jira] [Updated] (FLINK-15353) develop JDBCCatalog for Postgres, MySQL, and other relational databases

[ https://issues.apache.org/jira/browse/FLINK-15353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15353: - Summary: develop JDBCCatalog for Postgres, MySQL, and other relational databases (was: develop Abstract

[jira] [Updated] (FLINK-15353) develop JDBCCatalog

[ https://issues.apache.org/jira/browse/FLINK-15353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15353: - Summary: develop JDBCCatalog (was: develop JDBCCatalog for Postgres, MySQL, and other relational databa

[jira] [Created] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing

Bowen Li created FLINK-15645: Summary: enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Key: FLINK-15645 URL: https://issues.apache.org/jira/browse/FLINK-15645 Project: Flink

[jira] [Commented] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017499#comment-17017499 ] Bowen Li commented on FLINK-15595: -- Can you elaborate what you mean by "dropping CoreMo

[jira] [Updated] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15607: - Description: Due to that Hive functions are all built for batch processing, aggregate functions in Hive

[jira] [Updated] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15607: - Description: Due to that Hive functions are all built for batch processing, aggregate functions in Hive

[jira] [Updated] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15607: - Issue Type: Improvement (was: Task) > throw exception when users trying to use Hive aggregate functions

[jira] [Created] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

Bowen Li created FLINK-15607: Summary: throw exception when users trying to use Hive aggregate functions in streaming mode Key: FLINK-15607 URL: https://issues.apache.org/jira/browse/FLINK-15607 Project:

[jira] [Closed] (FLINK-15590) add section for current catalog and current database

[ https://issues.apache.org/jira/browse/FLINK-15590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15590. Resolution: Fixed 1.10: 4e39323b9c52fcd30019f8be31ea5f37d7595e1d > add section for current catalog and cu

[jira] [Closed] (FLINK-15589) remove beta tag from catalog and hive doc

[ https://issues.apache.org/jira/browse/FLINK-15589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15589. Resolution: Fixed 1.10: af93ca2502e8f083fda99aea7b6e720a597d2a0a > remove beta tag from catalog and hive

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016201#comment-17016201 ] Bowen Li commented on FLINK-15595: -- I agree built-in functions in FlinkSqlOperatorTable

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015649#comment-17015649 ] Bowen Li commented on FLINK-15595: -- The current behavior is actually exactly what FLIP-

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015637#comment-17015637 ] Bowen Li commented on FLINK-15592: -- I checked BuiltInFunctionDefinitions and there's no

[jira] [Created] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

Bowen Li created FLINK-15593: Summary: add doc to remind users not using Hive aggregate functions in streaming mode Key: FLINK-15593 URL: https://issues.apache.org/jira/browse/FLINK-15593 Project: Flink

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15591: - Fix Version/s: (was: 1.10.0) 1.11.0 > make up for feature parity by supporting CR

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15591: - Description: make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL as correspondin

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15591: - Summary: make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL (was: support CREA

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15591: - Fix Version/s: (was: 1.11.0) 1.10.0 > make up for feature parity by supporting CR

[jira] [Updated] (FLINK-15591) support CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15591: - Description: support CREATE TEMPORARY TABLE/VIEW in DDL as corresponding API to that in Table API. Table

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

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015554#comment-17015554 ] Bowen Li commented on FLINK-15349: -- can you help to triage this? [~ykt836] > add Catal

[jira] [Assigned] (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 reassigned FLINK-15349: Assignee: Kurt Young (was: Terry Wang) > add Catalog DDL support in FLIP-69 > --

[jira] [Commented] (FLINK-15591) support CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015553#comment-17015553 ] Bowen Li commented on FLINK-15591: -- can you help to triage this? [~ykt836] > support C

[jira] [Assigned] (FLINK-15591) support CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15591: Assignee: Kurt Young > support CREATE TEMPORARY TABLE/VIEW in DDL > -

[jira] [Updated] (FLINK-15591) support CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15591: - Description: support CREATE TEMPORARY TABLE/VIEW in DDL as corresponding API to that in Table API > sup

[jira] [Created] (FLINK-15591) support CREATE TEMPORARY TABLE/VIEW in DDL

Bowen Li created FLINK-15591: Summary: support CREATE TEMPORARY TABLE/VIEW in DDL Key: FLINK-15591 URL: https://issues.apache.org/jira/browse/FLINK-15591 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-15590) add section for current catalog and current database

Bowen Li created FLINK-15590: Summary: add section for current catalog and current database Key: FLINK-15590 URL: https://issues.apache.org/jira/browse/FLINK-15590 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-15590) add section for current catalog and current database

[ https://issues.apache.org/jira/browse/FLINK-15590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15590: - Component/s: (was: Deployment / Docker) Documentation > add section for current cat

[jira] [Created] (FLINK-15589) remove beta tag from catalog and hive doc

Bowen Li created FLINK-15589: Summary: remove beta tag from catalog and hive doc Key: FLINK-15589 URL: https://issues.apache.org/jira/browse/FLINK-15589 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015508#comment-17015508 ] Bowen Li commented on FLINK-11899: -- assigning to [~lzljs3620320] > Introduce vectorize

[jira] [Assigned] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-11899: Assignee: Jingsong Lee (was: Zhenqiu Huang) > Introduce vectorized parquet InputFormat for blink

[jira] [Commented] (FLINK-15126) migrate "show functions" from sql cli to sql parser

[ https://issues.apache.org/jira/browse/FLINK-15126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015507#comment-17015507 ] Bowen Li commented on FLINK-15126: -- let's make it 1.11 > migrate "show functions" from

[jira] [Commented] (FLINK-15576) remove isTemporary property from CatalogFunction API

[ https://issues.apache.org/jira/browse/FLINK-15576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015506#comment-17015506 ] Bowen Li commented on FLINK-15576: -- [~lzljs3620320] I think catalog API as of 1.10 are

[jira] [Updated] (FLINK-15126) migrate "show functions" from sql cli to sql parser

[ https://issues.apache.org/jira/browse/FLINK-15126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15126: - Fix Version/s: 1.11.0 > migrate "show functions" from sql cli to sql parser > --

[jira] [Closed] (FLINK-15576) remove isTemporary property from CatalogFunction API

[ https://issues.apache.org/jira/browse/FLINK-15576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15576. Resolution: Fixed 1.10: 7667d43cf216184818dac56d2c243c0c56f31ef1 > remove isTemporary property from Catal

[jira] [Created] (FLINK-15588) check registered udf via catalog API cannot be a scala inner class

Bowen Li created FLINK-15588: Summary: check registered udf via catalog API cannot be a scala inner class Key: FLINK-15588 URL: https://issues.apache.org/jira/browse/FLINK-15588 Project: Flink I

[jira] [Created] (FLINK-15576) remove isTemporary property from CatalogFunction API

Bowen Li created FLINK-15576: Summary: remove isTemporary property from CatalogFunction API Key: FLINK-15576 URL: https://issues.apache.org/jira/browse/FLINK-15576 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-15464) HiveTableSourceTest::testPartitionFilterDateTimestamp fails with Hive 1.x

[ https://issues.apache.org/jira/browse/FLINK-15464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15464. Assignee: Rui Li Resolution: Fixed 1.10: 3a13e1bf586b011e4018ab328190de308e1d82fd > HiveTableSource

[jira] [Closed] (FLINK-15515) Document that Hive connector should be used with blink planner

[ https://issues.apache.org/jira/browse/FLINK-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15515. Resolution: Fixed 1.10:  87d566f967fc3e4ded0150b57c87d7df035e447a  > Document that Hive connector should

[jira] [Assigned] (FLINK-15515) Document that Hive connector should be used with blink planner

[ https://issues.apache.org/jira/browse/FLINK-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15515: Assignee: Rui Li > Document that Hive connector should be used with blink planner > -

[jira] [Updated] (FLINK-15545) Separate runtime params and semantics params from Flink DDL for easier integration with catalogs and better user experience

[ https://issues.apache.org/jira/browse/FLINK-15545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15545: - Description: Currently Flink DDL mixes three types of params all together: * External data’s metadata:

[jira] [Updated] (FLINK-15545) Separate runtime params and semantics params from Flink DDL to DML for easier integration with catalogs and better user experience

[ https://issues.apache.org/jira/browse/FLINK-15545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15545: - Summary: Separate runtime params and semantics params from Flink DDL to DML for easier integration with

[jira] [Created] (FLINK-15545) Separate runtime params and semantics params from Flink DDL for easier integration with catalogs and better user experience

Bowen Li created FLINK-15545: Summary: Separate runtime params and semantics params from Flink DDL for easier integration with catalogs and better user experience Key: FLINK-15545 URL: https://issues.apache.org/jira/b

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012098#comment-17012098 ] Bowen Li commented on FLINK-11899: -- [~hpeter] do you plan to take on this? If not, I ca

[jira] [Updated] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-11899: - Fix Version/s: 1.11.0 > Introduce vectorized parquet InputFormat for blink runtime > ---

[jira] [Commented] (FLINK-12256) Implement Confluent Schema Registry Catalog

[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010182#comment-17010182 ] Bowen Li commented on FLINK-12256: -- Hi [~artsem.semianenka] , do you plan to continue w

[jira] [Updated] (FLINK-12256) Implement Confluent Schema Registry Catalog

[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12256: - Summary: Implement Confluent Schema Registry Catalog (was: Implement KafkaReadableCatalog) > Implement

[jira] [Updated] (FLINK-12256) Implement KafkaReadableCatalog

[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12256: - Fix Version/s: 1.11.0 > Implement KafkaReadableCatalog > -- > >

[jira] [Updated] (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 updated FLINK-14659: - Description: add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql parser to enabling loading/unload

[jira] [Closed] (FLINK-14863) remove default in-memory catalog from CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-14863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14863. Resolution: Invalid > remove default in-memory catalog from CatalogManager > -

[jira] [Updated] (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 updated FLINK-14659: - Description: add > add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql parser > -

[jira] [Updated] (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 updated FLINK-14659: - Fix Version/s: 1.11.0 > add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql parser > -

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