Hi all,
Just trying to make sure I haven't missed anything - after a cluster restart
all the uploaded jars are not available from the dashboard or REST API. So in
case we need to resubmit a new job from an already uploaded jar after a cluster
restart, it is my understanding that one needs to re
Shimin Yang created FLINK-10322:
---
Summary: Unused instance variable MetricRegistry in ResourceManager
Key: FLINK-10322
URL: https://issues.apache.org/jira/browse/FLINK-10322
Project: Flink
Issu
zhijiang created FLINK-10321:
Summary: Make the condition of broadcast partitioner simple
Key: FLINK-10321
URL: https://issues.apache.org/jira/browse/FLINK-10321
Project: Flink
Issue Type: Improv
陈梓立 created FLINK-10320:
---
Summary: Introduce JobMaster schedule micro-benchmark
Key: FLINK-10320
URL: https://issues.apache.org/jira/browse/FLINK-10320
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-10319:
---
Summary: Avoid requestPartitionState from JM but always try
retrigger
Key: FLINK-10319
URL: https://issues.apache.org/jira/browse/FLINK-10319
Project: Flink
Issue Type: Impro
We need your help to make the Apache Washington DC Roadshow on Dec 4th a
success.
What do we need most? Speakers!
We're bringing a unique DC flavor to this event by mixing Open Source
Software with talks about Apache projects as well as OSS CyberSecurity,
OSS in Government and and OSS Career
Ufuk Celebi created FLINK-10318:
---
Summary: Add option to build Hadoop-free job image to build.sh
Key: FLINK-10318
URL: https://issues.apache.org/jira/browse/FLINK-10318
Project: Flink
Issue Typ
Stephan Ewen created FLINK-10317:
Summary: Configure Metaspace size by default
Key: FLINK-10317
URL: https://issues.apache.org/jira/browse/FLINK-10317
Project: Flink
Issue Type: Bug
Great to hear that it works :-)
On Tue, Sep 11, 2018 at 9:28 AM Michael Gendelman wrote:
> Hi Till,
>
> Thanks for the great suggestion!
> Seems like it does the job. Here is a sample of the code:
>
> public class FlinkMain {
> public static void main(String[] args) throws Exception {
>
Hi Till,
Thanks for the great suggestion!
Seems like it does the job. Here is a sample of the code:
public class FlinkMain {
public static void main(String[] args) throws Exception {
ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
EsInputFormat kvEs
Many thanks Till!
I would create a JIRA for this feature and design a document attched with it.
I will let you know after ready! :)
Best,
Zhijiang
--
发件人：Till Rohrmann
发送时间：2018年9月7日(星期五) 22:01
收件人：Zhijiang(wangzhijiang999)
抄 送：
11 matches
Mail list logo
