clear query| facets| time Search criteria: .   Results from 1 to 10 from 24 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-16005] Propagate yarn.application.classpath from client to TaskManager Classpath - 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-02-28, 12:39
[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-02-20, 16:35
[FLINK-16006] Add host blacklist support for Flink YarnResourceManager - Flink - [issue]    Author: Zhenqiu Huang , 2020-02-20, 09:40
[FLINK-15768] Consolidate executor related class into same module in flink-clients - Flink - [issue]
...Currently, LocalExecutor and RemoteExecutor are in namespace org.apache.flink.client.deployment.executors, but AbstractJobClusterExecutor is underneath  org.apache.flink.client.deployme...    Author: Zhenqiu Huang , 2020-01-29, 10:23
[FLINK-14906] create and drop temp system functions from DDL to FunctionCatalog - Flink - [issue]    Author: Zhenqiu Huang , 2020-01-20, 13:48
[FLINK-14837] Support Function DDL in TableEnvironment - Flink - [issue]    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...    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...    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....    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....    Author: Zhenqiu Huang , 2019-12-10, 02:24