clear query| facets| time Search criteria: .   Results from 1 to 10 from 21 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-14906] create and drop temp system functions from DDL to FunctionCatalog - Flink - [issue]
http://issues.apache.org/jira/browse/FLINK-14906    Author: Zhenqiu Huang , 2020-01-20, 13:48
[FLINK-14837] Support Function DDL in TableEnvironment - Flink - [issue]
http://issues.apache.org/jira/browse/FLINK-14837    Author: Zhenqiu Huang , 2020-01-13, 09:11
[FLINK-15416] Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel - Flink - [issue]
...We run a flink with 256 TMs in production. The job internally has keyby logic. Thus, it builds a 256 * 256 communication channels. An outage happened when there is a chip internal link of on...
http://issues.apache.org/jira/browse/FLINK-15416    Author: Zhenqiu Huang , 2019-12-31, 15:31
[FLINK-14953] Parquet table source should use schema type to build FilterPredicate - Flink - [issue]
...The issue happens when the data type of value in predicate inferred from SQL doesn't match the parquet schema. For example, foo is a long type, foo < 1 is the predicate. Literal will be r...
http://issues.apache.org/jira/browse/FLINK-14953    Author: Zhenqiu Huang , 2019-12-11, 06:46
[FLINK-15165] support upsert (Hive ACID) in Hive sink - Flink - [issue]
...Lots of our use cases need to backfill to existing hive table. It requires support for apache hoodie / Hive ACID....
http://issues.apache.org/jira/browse/FLINK-15165    Author: Zhenqiu Huang , 2019-12-11, 03:24
[FLINK-15164] Introduce ParquetColumnarRowSplitReader to parquet format - Flink - [issue]
...With ParquetColumnarRowSplitReader support, the hive connector can directly read data stored as parquet format....
http://issues.apache.org/jira/browse/FLINK-15164    Author: Zhenqiu Huang , 2019-12-10, 02:24
[FLINK-14033] Distributed caches are not registered in Yarn Per Job Cluster Mode - Flink - [issue]
...CacheFiles in StreamExecutionEnvironment is not used in Job Submission in the Yarn per job cluster mode. Compare to the job submission in session cluster mode that will upload distributed ca...
http://issues.apache.org/jira/browse/FLINK-14033    Author: Zhenqiu Huang , 2019-12-04, 14:27
[FLINK-14982] YARN IT Test Case log config is mistakenly disabled - Flink - [issue]
...The FLINK-14630 Make the yarn APPLICATION_LOG_CONFIG_FILE an internal option changed how log config is shipped in YarnClusterDescritor. Currently, we need to rely on the yarn.log-config-file...
http://issues.apache.org/jira/browse/FLINK-14982    Author: Zhenqiu Huang , 2019-12-03, 18:28
[FLINK-14841] Add create and drop function DDL in parser - Flink - [issue]
http://issues.apache.org/jira/browse/FLINK-14841    Author: Zhenqiu Huang , 2019-11-20, 18:03
[FLINK-14711] Add Alter Function and Show Functions in SQL Parser - Flink - [issue]
...It is a sibling ticket for https://issues.apache.org/jira/browse/FLINK-7151. Alter Function StatementALTER [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name...
http://issues.apache.org/jira/browse/FLINK-14711    Author: Zhenqiu Huang , 2019-11-19, 23:04