clear query| facets| time Search criteria: .   Results from 1 to 10 from 24 (0.0s).
Loading phrases to help you
refine your search...
[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 , 2020-07-03, 06:51
[FLINK-12343] Allow set file.replication in Yarn Configuration - Flink - [issue]
...Currently, FlinkYarnSessionCli upload jars into hdfs with default 3 replications. From our production experience, we find that 3 replications will block big job (256 containers) to launch, w...
http://issues.apache.org/jira/browse/FLINK-12343    Author: Zhenqiu Huang , 2020-06-19, 23:02
[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 , 2020-06-02, 08:43
[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 , 2020-05-20, 08:41
[FLINK-14841] Add create and drop function DDL in parser - Flink - [issue]
http://issues.apache.org/jira/browse/FLINK-14841    Author: Zhenqiu Huang , 2020-05-15, 06:38
[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 , 2020-04-09, 16:20
[FLINK-16005] Support yarn and hadoop config override - Flink - [issue]
...When Flink users want to override the hadoop yarn container classpath, they should just specify the yarn.application.classpath in yarn-site.xml from cli side. But currently, the classpath se...
http://issues.apache.org/jira/browse/FLINK-16005    Author: Zhenqiu Huang , 2020-03-27, 04:35
[CALCITE-3349] Add Function DDL into SqlKind DDL enum - Calcite - [issue]
...Currently, Create Function, Drop Function are not added into SqlKind DDL enum....
http://issues.apache.org/jira/browse/CALCITE-3349    Author: Zhenqiu Huang , 2020-03-06, 04:33
[FLINK-14837] Support Function DDL in TableEnvironment - Flink - [issue]
http://issues.apache.org/jira/browse/FLINK-14837    Author: Zhenqiu Huang , 2020-03-03, 16:56
[FLINK-16006] Add host blacklist support for Flink YarnResourceManager - Flink - [issue]
http://issues.apache.org/jira/browse/FLINK-16006    Author: Zhenqiu Huang , 2020-02-20, 09:40