Bowen Li created FLINK-17392:
Summary: enable configuring minicluster in Flink SQL in IDE
Key: FLINK-17392
URL: https://issues.apache.org/jira/browse/FLINK-17392
Project: Flink
Issue Type:
Bowen Li created FLINK-17333:
Summary: add doc for "create ddl"
Key: FLINK-17333
URL: https://issues.apache.org/jira/browse/FLINK-17333
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-17175:
Summary: StringUtils.arrayToString() should consider Object[]
lastly
Key: FLINK-17175
URL: https://issues.apache.org/jira/browse/FLINK-17175
Project: Flink
Issue
Bowen Li created FLINK-17037:
Summary: add e2e tests for reading array data types from postgres
with JDBCTableSource and PostgresCatalog
Key: FLINK-17037
URL: https://issues.apache.org/jira/browse/FLINK-17037
Bowen Li created FLINK-16820:
Summary: support reading array of timestamp, data, and time in
JDBCTableSource
Key: FLINK-16820
URL: https://issues.apache.org/jira/browse/FLINK-16820
Project: Flink
Bowen Li created FLINK-16817:
Summary: StringUtils.arrayToString() doesn't convert byte[][]
correctly
Key: FLINK-16817
URL: https://issues.apache.org/jira/browse/FLINK-16817
Project: Flink
Bowen Li created FLINK-16816:
Summary: planner doesn't parse timestamp array correctly
Key: FLINK-16816
URL: https://issues.apache.org/jira/browse/FLINK-16816
Project: Flink
Issue Type: Bug
Bowen Li created FLINK-16815:
Summary: add e2e tests for reading from postgres with
JDBCTableSource and PostgresCatalog
Key: FLINK-16815
URL: https://issues.apache.org/jira/browse/FLINK-16815
Project:
Bowen Li created FLINK-16814:
Summary: StringUtils.arrayToString() doesn't convert byte[]
correctly
Key: FLINK-16814
URL: https://issues.apache.org/jira/browse/FLINK-16814
Project: Flink
Issue
Bowen Li created FLINK-16813:
Summary: JDBCInputFormat doesn't correctly map Short
Key: FLINK-16813
URL: https://issues.apache.org/jira/browse/FLINK-16813
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-16812:
Summary: introduce PostgresRowConverter
Key: FLINK-16812
URL: https://issues.apache.org/jira/browse/FLINK-16812
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-16811:
Summary: introduce JDBCRowConverter
Key: FLINK-16811
URL: https://issues.apache.org/jira/browse/FLINK-16811
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-16810:
Summary: add back PostgresCatalogITCase
Key: FLINK-16810
URL: https://issues.apache.org/jira/browse/FLINK-16810
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-16781:
Summary: add built-in cache mechanism for LookupableTableSource in
lookup join
Key: FLINK-16781
URL: https://issues.apache.org/jira/browse/FLINK-16781
Project: Flink
Bowen Li created FLINK-16780:
Summary: improve Flink lookup join
Key: FLINK-16780
URL: https://issues.apache.org/jira/browse/FLINK-16780
Project: Flink
Issue Type: New Feature
Bowen Li created FLINK-16702:
Summary: develop JDBCCatalogFactory for service discovery
Key: FLINK-16702
URL: https://issues.apache.org/jira/browse/FLINK-16702
Project: Flink
Issue Type:
Bowen Li created FLINK-16575:
Summary: develop HBaseCatalog to integrate HBase metadata into
Flink
Key: FLINK-16575
URL: https://issues.apache.org/jira/browse/FLINK-16575
Project: Flink
Issue
Bowen Li created FLINK-16498:
Summary: make Postgres table work end-2-end in Flink SQL with
PostgresJDBCCatalog
Key: FLINK-16498
URL: https://issues.apache.org/jira/browse/FLINK-16498
Project: Flink
Bowen Li created FLINK-16474:
Summary: develop OracleJDBCCatalog to connect Flink with Oracle
databases and ecosystem
Key: FLINK-16474
URL: https://issues.apache.org/jira/browse/FLINK-16474
Project:
Bowen Li created FLINK-16473:
Summary: add documentation for PostgresJDBCCatalog
Key: FLINK-16473
URL: https://issues.apache.org/jira/browse/FLINK-16473
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-16472:
Summary: support precision of timestamp and time data types
Key: FLINK-16472
URL: https://issues.apache.org/jira/browse/FLINK-16472
Project: Flink
Issue Type:
Bowen Li created FLINK-16471:
Summary: develop PostgresJDBCCatalog
Key: FLINK-16471
URL: https://issues.apache.org/jira/browse/FLINK-16471
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-16448:
Summary: add documentation for Hive table sink parallelism setting
strategy
Key: FLINK-16448
URL: https://issues.apache.org/jira/browse/FLINK-16448
Project: Flink
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:
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
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
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
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:
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
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
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
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
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
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
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
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
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:
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
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
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:
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
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
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
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:
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
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
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
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
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:
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:
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
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
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
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
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
Bowen Li created FLINK-15262:
Summary: kafka connector doesn't read from beginning immediately
when 'connector.startup-mode' = 'earliest-offset'
Key: FLINK-15262
URL:
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
Bowen Li created FLINK-15259:
Summary: HiveInspector.toInspectors() should convert Flink
constant to Hive constant
Key: FLINK-15259
URL: https://issues.apache.org/jira/browse/FLINK-15259
Project: Flink
Bowen Li created FLINK-15258:
Summary: HiveModuleFactory doesn't take hive-version
Key: FLINK-15258
URL: https://issues.apache.org/jira/browse/FLINK-15258
Project: Flink
Issue Type: Bug
Bowen Li created FLINK-15257:
Summary: convert HiveCatalogITCase.testCsvTableViaAPI() to use
blink planner
Key: FLINK-15257
URL: https://issues.apache.org/jira/browse/FLINK-15257
Project: Flink
Bowen Li created FLINK-15256:
Summary: unable to drop table in HiveCatalogITCase
Key: FLINK-15256
URL: https://issues.apache.org/jira/browse/FLINK-15256
Project: Flink
Issue Type: Bug
Bowen Li created FLINK-15255:
Summary: document how to create Hive table from java API and DDL
Key: FLINK-15255
URL: https://issues.apache.org/jira/browse/FLINK-15255
Project: Flink
Issue Type:
Bowen Li created FLINK-15254:
Summary: hive module cannot be named "hive"
Key: FLINK-15254
URL: https://issues.apache.org/jira/browse/FLINK-15254
Project: Flink
Issue Type: Test
Bowen Li created FLINK-15240:
Summary: is_generic key is missing for Flink table stored in
HiveCatalog
Key: FLINK-15240
URL: https://issues.apache.org/jira/browse/FLINK-15240
Project: Flink
Bowen Li created FLINK-15235:
Summary: create a Flink distribution for hive that includes all
Hive dependencies
Key: FLINK-15235
URL: https://issues.apache.org/jira/browse/FLINK-15235
Project: Flink
Bowen Li created FLINK-15234:
Summary: hive table created from flink catalog table cannot have
null properties in parameters
Key: FLINK-15234
URL: https://issues.apache.org/jira/browse/FLINK-15234
Bowen Li created FLINK-15229:
Summary: DDL for kafka connector following documentation doesn't
work
Key: FLINK-15229
URL: https://issues.apache.org/jira/browse/FLINK-15229
Project: Flink
Issue
Bowen Li created FLINK-15208:
Summary: support client to submit both an online streaming job and
an offline batch job based on dynamic catalog table
Key: FLINK-15208
URL:
Bowen Li created FLINK-15206:
Summary: support dynamic catalog table for unified SQL job
Key: FLINK-15206
URL: https://issues.apache.org/jira/browse/FLINK-15206
Project: Flink
Issue Type: New
Bowen Li created FLINK-15205:
Summary: add doc and exmaple of INSERT OVERWRITE and insert into
partitioned table for Hive connector
Key: FLINK-15205
URL: https://issues.apache.org/jira/browse/FLINK-15205
Bowen Li created FLINK-15204:
Summary: add documentation for Flink-Hive timestamp conversions in
table and udf
Key: FLINK-15204
URL: https://issues.apache.org/jira/browse/FLINK-15204
Project: Flink
Bowen Li created FLINK-15203:
Summary: rephrase Hive's data types doc
Key: FLINK-15203
URL: https://issues.apache.org/jira/browse/FLINK-15203
Project: Flink
Issue Type: Task
Bowen Li created FLINK-15192:
Summary: consider split 'SQL' page into multiple sub pages for
better clarity
Key: FLINK-15192
URL: https://issues.apache.org/jira/browse/FLINK-15192
Project: Flink
Bowen Li created FLINK-15190:
Summary: add documentation for DDL in FLIP-69
Key: FLINK-15190
URL: https://issues.apache.org/jira/browse/FLINK-15190
Project: Flink
Issue Type: Task
Bowen Li created FLINK-15189:
Summary: add documentation for catalog view and hive view
Key: FLINK-15189
URL: https://issues.apache.org/jira/browse/FLINK-15189
Project: Flink
Issue Type: Task
Bowen Li created FLINK-15188:
Summary: add builder for catalog objects
Key: FLINK-15188
URL: https://issues.apache.org/jira/browse/FLINK-15188
Project: Flink
Issue Type: Task
Bowen Li created FLINK-15184:
Summary: write guest post for Flink-Hive integration for AWS and
Cloudera
Key: FLINK-15184
URL: https://issues.apache.org/jira/browse/FLINK-15184
Project: Flink
Bowen Li created FLINK-15133:
Summary: support sql_alchemy in Flink for broader python sql
integration
Key: FLINK-15133
URL: https://issues.apache.org/jira/browse/FLINK-15133
Project: Flink
Bowen Li created FLINK-15127:
Summary: rename CreateFunctionOperation, DropFunctionOperation,
AlterFunctionOperation to CreateCatalogFunctionOperation,
DropCatalogFunctionOperation, AlterCatalogFunctionOperation
Key: FLINK-15127
Bowen Li created FLINK-15126:
Summary: migrate "show functions" from sql cli to sql parser
Key: FLINK-15126
URL: https://issues.apache.org/jira/browse/FLINK-15126
Project: Flink
Issue Type:
Bowen Li created FLINK-15117:
Summary: JoinITCase.testFullJoinWithLeftLocalPred fails
Key: FLINK-15117
URL: https://issues.apache.org/jira/browse/FLINK-15117
Project: Flink
Issue Type: Bug
Bowen Li created FLINK-15019:
Summary: publish blog and document Flink-Hive benchmark v.s. Hive
on MR/Tez
Key: FLINK-15019
URL: https://issues.apache.org/jira/browse/FLINK-15019
Project: Flink
Bowen Li created FLINK-15017:
Summary: add a thrift jdbc/odbc server for Flink
Key: FLINK-15017
URL: https://issues.apache.org/jira/browse/FLINK-15017
Project: Flink
Issue Type: New Feature
Bowen Li created FLINK-15015:
Summary: add documentation for using orc reader in hive connector
Key: FLINK-15015
URL: https://issues.apache.org/jira/browse/FLINK-15015
Project: Flink
Issue Type:
Bowen Li created FLINK-14980:
Summary: add documentation and example for function DDL
Key: FLINK-14980
URL: https://issues.apache.org/jira/browse/FLINK-14980
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-14914:
Summary: refactor CatalogFunction interface and impls to add
language field
Key: FLINK-14914
URL: https://issues.apache.org/jira/browse/FLINK-14914
Project: Flink
Bowen Li created FLINK-14913:
Summary: refactor CatalogFunction interface and impls by removing
properties map
Key: FLINK-14913
URL: https://issues.apache.org/jira/browse/FLINK-14913
Project: Flink
Bowen Li created FLINK-14912:
Summary: register,drop, and alter catalog functions from DDL to
FunctionCatalog
Key: FLINK-14912
URL: https://issues.apache.org/jira/browse/FLINK-14912
Project: Flink
Bowen Li created FLINK-14911:
Summary: register temp catalog functions created by DDL to
FunctionCatalog
Key: FLINK-14911
URL: https://issues.apache.org/jira/browse/FLINK-14911
Project: Flink
Bowen Li created FLINK-14863:
Summary: remove default in-memory catalog from CatalogManager
Key: FLINK-14863
URL: https://issues.apache.org/jira/browse/FLINK-14863
Project: Flink
Issue Type:
Bowen Li created FLINK-14842:
Summary: add logging for functions loaded from modules
Key: FLINK-14842
URL: https://issues.apache.org/jira/browse/FLINK-14842
Project: Flink
Issue Type:
Bowen Li created FLINK-14728:
Summary: add reminder for users of potential thread safety issues
of hive built-in function
Key: FLINK-14728
URL: https://issues.apache.org/jira/browse/FLINK-14728
Project:
Bowen Li created FLINK-14727:
Summary: update doc of supported Hive versions
Key: FLINK-14727
URL: https://issues.apache.org/jira/browse/FLINK-14727
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-14726:
Summary: avoid creating new HiveShim instance every time when
calling HiveShimLoader.loadHiveShim()
Key: FLINK-14726
URL: https://issues.apache.org/jira/browse/FLINK-14726
Bowen Li created FLINK-14661:
Summary: rename args of setters in sql cli Environment
Key: FLINK-14661
URL: https://issues.apache.org/jira/browse/FLINK-14661
Project: Flink
Issue Type:
Bowen Li created FLINK-14660:
Summary: add 'SHOW MODULES' sql command
Key: FLINK-14660
URL: https://issues.apache.org/jira/browse/FLINK-14660
Project: Flink
Issue Type: Sub-task
Bowen Li created FLINK-14659:
Summary: add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql
parser
Key: FLINK-14659
URL: https://issues.apache.org/jira/browse/FLINK-14659
Project: Flink
Bowen Li created FLINK-14638:
Summary: move functions related docs to a new single, unified dir
/dev/table/functions
Key: FLINK-14638
URL: https://issues.apache.org/jira/browse/FLINK-14638
Project: Flink
Bowen Li created FLINK-14579:
Summary: enable SQL CLI to configure modules via yaml config
Key: FLINK-14579
URL: https://issues.apache.org/jira/browse/FLINK-14579
Project: Flink
Issue Type:
Bowen Li created FLINK-14580:
Summary: add HiveModuleFactory, HiveModuleDescriptor, and
HiveModuleValidator
Key: FLINK-14580
URL: https://issues.apache.org/jira/browse/FLINK-14580
Project: Flink
1 - 100 of 320 matches
Mail list logo
