zhangjing created FLINK-4633:
Summary: Implement new Client
Key: FLINK-4633
URL: https://issues.apache.org/jira/browse/FLINK-4633
Project: Flink
Issue Type: Sub-task
Components: Cluster
刘喆 created FLINK-4632:
-
Summary: when yarn nodemanager lost, flink hung
Key: FLINK-4632
URL: https://issues.apache.org/jira/browse/FLINK-4632
Project: Flink
Issue Type: Bug
Components: Distrib
I have new findings & subsequently relative improvements.Am testing as we
speak. 4 Beam server nodes , Azure A11 & 2 Kafka nodes same config.I had keep
state somewhere. I went with Redis. I found it to be a major bottle neck as
Beam nodes constantly are going across NW to update its repository.S
Has anyone else run these kind of benchmarks? Would love to hear more
people'e experience and details about those benchmarks.
Regards
Sumit Chawla
On Sun, Sep 18, 2016 at 2:01 PM, Chawla,Sumit
wrote:
> Hi Amir
>
> Would it be possible for you to share the numbers? Also share if possible
> you
Hi Amir
Would it be possible for you to share the numbers? Also share if possible
your configuration details.
Regards
Sumit Chawla
On Fri, Sep 16, 2016 at 12:18 PM, amir bahmanyari <
amirto...@yahoo.com.invalid> wrote:
> Hi Fabian,FYI. This is report on other engines we did the same type of
>
Hi Aljoscha,
A)
I tried the approach where we set the ProcessingTime explicitly by
converting DataStream input to DataStream> using map
function and below are my observations:
1. All the current code which uses TimeEvictor (which will be by default
changed to ProcessingTimeEvictor) will be forced
Avihai Berkovitz created FLINK-4631:
---
Summary: NullPointerException during stream task cleanup
Key: FLINK-4631
URL: https://issues.apache.org/jira/browse/FLINK-4631
Project: Flink
Issue Typ
Hi Henry,
Here is the FLIP:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65870673
Thanks,
David
2016-09-15 12:26 GMT+08:00 Henry Saputra :
> HI David,
>
> Thanks so much for the interest to contribute to Apache Flink.
>
> To help review and DISCUSS for new feature in Flink,
shijinkui created FLINK-4630:
Summary: add netty tcp source support
Key: FLINK-4630
URL: https://issues.apache.org/jira/browse/FLINK-4630
Project: Flink
Issue Type: New Feature
Componen
