[jira] [Created] (FLINK-33871) Reduce getTable call for hive client and optimize graph generation time

hehuiyuan created FLINK-33871: - Summary: Reduce getTable call for hive client and optimize graph generation time Key: FLINK-33871 URL: https://issues.apache.org/jira/browse/FLINK-33871 Project: Flink

[jira] [Created] (FLINK-31086) [DOC]update connector lable for blackhole and kafka

hehuiyuan created FLINK-31086: - Summary: [DOC]update connector lable for blackhole and kafka Key: FLINK-31086 URL: https://issues.apache.org/jira/browse/FLINK-31086 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

hehuiyuan created FLINK-30679: - Summary: Can not load the data of hive dim table when project-push-down is introduced Key: FLINK-30679 URL: https://issues.apache.org/jira/browse/FLINK-30679 Project: Flink

[jira] [Created] (FLINK-29553) Support UNIX_TIMESTAMP in Table API

hehuiyuan created FLINK-29553: - Summary: Support UNIX_TIMESTAMP in Table API Key: FLINK-29553 URL: https://issues.apache.org/jira/browse/FLINK-29553 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29052) Support TO_TIMESTAMP built-in function in Table API

hehuiyuan created FLINK-29052: - Summary: Support TO_TIMESTAMP built-in function in Table API Key: FLINK-29052 URL: https://issues.apache.org/jira/browse/FLINK-29052 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-28750) Whether to add comment for hive table

hehuiyuan created FLINK-28750: - Summary: Whether to add comment for hive table Key: FLINK-28750 URL: https://issues.apache.org/jira/browse/FLINK-28750 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

hehuiyuan created FLINK-28716: - Summary: uploading multiple files/form datas fail randomly when use rest api Key: FLINK-28716 URL: https://issues.apache.org/jira/browse/FLINK-28716 Project: Flink

[jira] [Created] (FLINK-28375) Whether to consider adding other data type to support for last_value function

hehuiyuan created FLINK-28375: - Summary: Whether to consider adding other data type to support for last_value function Key: FLINK-28375 URL: https://issues.apache.org/jira/browse/FLINK-28375 Project: Flin

[jira] [Created] (FLINK-27238) The HiveGenericUDTF should support primitive array，for example Array Array ...

hehuiyuan created FLINK-27238: - Summary: The HiveGenericUDTF should support primitive array，for example Array Array ... Key: FLINK-27238 URL: https://issues.apache.org/jira/browse/FLINK-27238 Project: Fli

[jira] [Created] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed.

hehuiyuan created FLINK-27194: - Summary: Whether to consider adding the configuration of ignore when data deserialization failed. Key: FLINK-27194 URL: https://issues.apache.org/jira/browse/FLINK-27194 Pr

[jira] [Created] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval

hehuiyuan created FLINK-26848: - Summary: JDBC don't flush data when disable flush-max-rows and flush-interval Key: FLINK-26848 URL: https://issues.apache.org/jira/browse/FLINK-26848 Project: Flink

[jira] [Created] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

hehuiyuan created FLINK-26565: - Summary: Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter Key: FLINK-26565 URL: https://i

[jira] [Created] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

hehuiyuan created FLINK-26498: - Summary: The window result may not have been emitted when use window emit feature and use lateTrigger. Key: FLINK-26498 URL: https://issues.apache.org/jira/browse/FLINK-26498

[jira] [Created] (FLINK-26320) Update hive doc for 1 m->1 min

hehuiyuan created FLINK-26320: - Summary: Update hive doc for 1 m->1 min Key: FLINK-26320 URL: https://issues.apache.org/jira/browse/FLINK-26320 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-25262) Support to send data to lookup table for KeyGroupStreamPartitioner way for SQL

hehuiyuan created FLINK-25262: - Summary: Support to send data to lookup table for KeyGroupStreamPartitioner way for SQL Key: FLINK-25262 URL: https://issues.apache.org/jira/browse/FLINK-25262 Project: Fl

[jira] [Created] (FLINK-24620) Add partition discovery for kafka sink when `sink.partitioner`= 'fix'

hehuiyuan created FLINK-24620: - Summary: Add partition discovery for kafka sink when `sink.partitioner`= 'fix' Key: FLINK-24620 URL: https://issues.apache.org/jira/browse/FLINK-24620 Project: Flink

[jira] [Created] (FLINK-23810) Print sql when parse failed , which is convenient to find error

hehuiyuan created FLINK-23810: - Summary: Print sql when parse failed , which is convenient to find error Key: FLINK-23810 URL: https://issues.apache.org/jira/browse/FLINK-23810 Project: Flink

[jira] [Created] (FLINK-23604) 'csv.disable-quote-character' can not take effect during deserialization for old csv format

hehuiyuan created FLINK-23604: - Summary: 'csv.disable-quote-character' can not take effect during deserialization for old csv format Key: FLINK-23604 URL: https://issues.apache.org/jira/browse/FLINK-23604

[jira] [Created] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true and threre is NPE question when use `new String(message) ` if message = null

hehuiyuan created FLINK-23237: - Summary: Add log to print data that failed to deserialize when ignore-parse-error=true and threre is NPE question when use `new String(message) ` if message = null Key: FLINK-23237

[jira] [Created] (FLINK-22976) Whether to consider adding config-option to control whether to exclude record.key value from record.value value

hehuiyuan created FLINK-22976: - Summary: Whether to consider adding config-option to control whether to exclude record.key value from record.value value Key: FLINK-22976 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

hehuiyuan created FLINK-22954: - Summary: Don't support consuming update and delete changes when use table function that does not contain table field Key: FLINK-22954 URL: https://issues.apache.org/jira/browse/FLINK-22

[jira] [Created] (FLINK-22617) Add log when create bulk format

hehuiyuan created FLINK-22617: - Summary: Add log when create bulk format Key: FLINK-22617 URL: https://issues.apache.org/jira/browse/FLINK-22617 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-22400) NPE problem when call HiveInspectors.toFlinkObject for hive-exec 2.0.0

hehuiyuan created FLINK-22400: - Summary: NPE problem when call HiveInspectors.toFlinkObject for hive-exec 2.0.0 Key: FLINK-22400 URL: https://issues.apache.org/jira/browse/FLINK-22400 Project: Flink

[jira] [Created] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

hehuiyuan created FLINK-22263: - Summary: Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource Key: FLINK-22263 URL: https://issues.apache.org/jira/browse/FLINK-22263

[jira] [Created] (FLINK-22174) `csv.quote-character` does not work for csv format when sink

hehuiyuan created FLINK-22174: - Summary: `csv.quote-character` does not work for csv format when sink Key: FLINK-22174 URL: https://issues.apache.org/jira/browse/FLINK-22174 Project: Flink I

[jira] [Created] (FLINK-21930) There are some error for hive_read_writer.md

hehuiyuan created FLINK-21930: - Summary: There are some error for hive_read_writer.md Key: FLINK-21930 URL: https://issues.apache.org/jira/browse/FLINK-21930 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first

hehuiyuan created FLINK-21829: - Summary: create HiveCatalog with custom hadoopconfdir first Key: FLINK-21829 URL: https://issues.apache.org/jira/browse/FLINK-21829 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-21284) Non-deterministic UDF functions return different values

hehuiyuan created FLINK-21284: - Summary: Non-deterministic UDF functions return different values Key: FLINK-21284 URL: https://issues.apache.org/jira/browse/FLINK-21284 Project: Flink Issue Type:

[jira] [Created] (FLINK-20771) Hive partition is not added when there is a lot of data

hehuiyuan created FLINK-20771: - Summary: Hive partition is not added when there is a lot of data Key: FLINK-20771 URL: https://issues.apache.org/jira/browse/FLINK-20771 Project: Flink Issue Type:

[jira] [Created] (FLINK-20318) Fix cast question for properies() method in kafka ConnectorDescriptor

hehuiyuan created FLINK-20318: - Summary: Fix cast question for properies() method in kafka ConnectorDescriptor Key: FLINK-20318 URL: https://issues.apache.org/jira/browse/FLINK-20318 Project: Flink

[jira] [Created] (FLINK-20301) Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible

hehuiyuan created FLINK-20301: - Summary: Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible Key: FLINK-20301 URL: https://issues.apache.org/jira/browse/FLINK-20301 Project: Fli

[jira] [Created] (FLINK-19686) Cast question for data | time

hehuiyuan created FLINK-19686: - Summary: Cast question for data | time Key: FLINK-19686 URL: https://issues.apache.org/jira/browse/FLINK-19686 Project: Flink Issue Type: Wish Component

[jira] [Created] (FLINK-18613) How to support retract & upsert sink for a TableSink ?

hehuiyuan created FLINK-18613: - Summary: How to support retract & upsert sink for a TableSink ? Key: FLINK-18613 URL: https://issues.apache.org/jira/browse/FLINK-18613 Project: Flink Issue Type:

[jira] [Created] (FLINK-18339) ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink

hehuiyuan created FLINK-18339: - Summary: ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink Key: FLINK-18339 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-18145) Segment optimization does not work ?

hehuiyuan created FLINK-18145: - Summary: Segment optimization does not work ? Key: FLINK-18145 URL: https://issues.apache.org/jira/browse/FLINK-18145 Project: Flink Issue Type: Wish R

[jira] [Created] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

hehuiyuan created FLINK-17117: - Summary: There are an useless cast operation for sql on blink when generate code Key: FLINK-17117 URL: https://issues.apache.org/jira/browse/FLINK-17117 Project: Flink

[jira] [Created] (FLINK-16704) Document has some error for connect.md

hehuiyuan created FLINK-16704: - Summary: Document has some error for connect.md Key: FLINK-16704 URL: https://issues.apache.org/jira/browse/FLINK-16704 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

hehuiyuan created FLINK-16584: - Summary: Whether to support the long type field in table planner when the source is kafka and event time field's type is long Key: FLINK-16584 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-16465) Add more detailed instructions for TableSink

hehuiyuan created FLINK-16465: - Summary: Add more detailed instructions for TableSink Key: FLINK-16465 URL: https://issues.apache.org/jira/browse/FLINK-16465 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-16463) CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink

hehuiyuan created FLINK-16463: - Summary: CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink Key: FLINK-16463 URL: https://issues.apache.org/jira/browse/FLINK-16463

[jira] [Created] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

hehuiyuan created FLINK-15610: - Summary: How to achieve the udf that the number of return column is uncertain Key: FLINK-15610 URL: https://issues.apache.org/jira/browse/FLINK-15610 Project: Flink

[jira] [Created] (FLINK-15596) Support key-value messages for kafka producer for flink SQL \Tbale

hehuiyuan created FLINK-15596: - Summary: Support key-value messages for kafka producer for flink SQL \Tbale Key: FLINK-15596 URL: https://issues.apache.org/jira/browse/FLINK-15596 Project: Flink

[jira] [Created] (FLINK-15404) How to insert hive table for different catalog

hehuiyuan created FLINK-15404: - Summary: How to insert hive table for different catalog Key: FLINK-15404 URL: https://issues.apache.org/jira/browse/FLINK-15404 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-15326) Add document description for DECIMAL(38, 18) when the sink table uses json schema

hehuiyuan created FLINK-15326: - Summary: Add document description for DECIMAL(38, 18) when the sink table uses json schema Key: FLINK-15326 URL: https://issues.apache.org/jira/browse/FLINK-15326 Project:

[jira] [Created] (FLINK-15159) the string of json is mapped to VARCHAR or STRING?

hehuiyuan created FLINK-15159: - Summary: the string of json is mapped to VARCHAR or STRING? Key: FLINK-15159 URL: https://issues.apache.org/jira/browse/FLINK-15159 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-15158) Why convert integer to bigdecimal for formart-json when kafka is used

hehuiyuan created FLINK-15158: - Summary: Why convert integer to bigdecimal for formart-json when kafka is used Key: FLINK-15158 URL: https://issues.apache.org/jira/browse/FLINK-15158 Project: Flink

[jira] [Created] (FLINK-15146) The value of `cleanupSize` should be grater than 0 for `IncrementalCleanupStrategy`

hehuiyuan created FLINK-15146: - Summary: The value of `cleanupSize` should be grater than 0 for `IncrementalCleanupStrategy` Key: FLINK-15146 URL: https://issues.apache.org/jira/browse/FLINK-15146 Project

[jira] [Created] (FLINK-14639) Fix the document of Metircs that has an error for `User Scope`

hehuiyuan created FLINK-14639: - Summary: Fix the document of Metircs that has an error for `User Scope` Key: FLINK-14639 URL: https://issues.apache.org/jira/browse/FLINK-14639 Project: Flink I

[jira] [Created] (FLINK-14550) can't use proctime attribute when register datastream for table and exist nested fields

hehuiyuan created FLINK-14550: - Summary: can't use proctime attribute when register datastream for table and exist nested fields Key: FLINK-14550 URL: https://issues.apache.org/jira/browse/FLINK-14550 Pro

[jira] [Created] (FLINK-13810) Update `Elasticsearch Connector` label

hehuiyuan created FLINK-13810: - Summary: Update `Elasticsearch Connector` label Key: FLINK-13810 URL: https://issues.apache.org/jira/browse/FLINK-13810 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-13757) Document error for `logical functions`

hehuiyuan created FLINK-13757: - Summary: Document error for `logical functions` Key: FLINK-13757 URL: https://issues.apache.org/jira/browse/FLINK-13757 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-13756) Modify Code Annotations for findAndCreateTableSource in TableFactoryUtil

hehuiyuan created FLINK-13756: - Summary: Modify Code Annotations for findAndCreateTableSource in TableFactoryUtil Key: FLINK-13756 URL: https://issues.apache.org/jira/browse/FLINK-13756 Project: Flink

[jira] [Created] (FLINK-13183) Add PrintTableSink for Table & SQL APi

hehuiyuan created FLINK-13183: - Summary: Add PrintTableSink for Table & SQL APi Key: FLINK-13183 URL: https://issues.apache.org/jira/browse/FLINK-13183 Project: Flink Issue Type: Wish C

[jira] [Created] (FLINK-13181) Add a constructor function to CsvTableSink

hehuiyuan created FLINK-13181: - Summary: Add a constructor function to CsvTableSink Key: FLINK-13181 URL: https://issues.apache.org/jira/browse/FLINK-13181 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13180) Add a constructor function to CsvTableSink

hehuiyuan created FLINK-13180: - Summary: Add a constructor function to CsvTableSink Key: FLINK-13180 URL: https://issues.apache.org/jira/browse/FLINK-13180 Project: Flink Issue Type: Improvement