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...    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...    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....    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...    Author: Zhenqiu Huang , 2020-05-20, 08:41
[FLINK-14841] Add create and drop function DDL in parser - Flink - [issue]    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...    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...    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....    Author: Zhenqiu Huang , 2020-03-06, 04:33
[FLINK-14837] Support Function DDL in TableEnvironment - Flink - [issue]    Author: Zhenqiu Huang , 2020-03-03, 16:56
[FLINK-16006] Add host blacklist support for Flink YarnResourceManager - Flink - [issue]    Author: Zhenqiu Huang , 2020-02-20, 09:40