[jira] [Created] (FLINK-4580) Check that the RpcEndpoint supports the specified RpcGateway

Till Rohrmann created FLINK-4580: Summary: Check that the RpcEndpoint supports the specified RpcGateway Key: FLINK-4580 URL: https://issues.apache.org/jira/browse/FLINK-4580 Project: Flink

Re: [DISCUSS] FLIP-11: Table API Stream Aggregations

Hi Jark, you had asked for non-windowed aggregates in the Table API a few times. FLIP-11 proposes row-window aggregates which are a generalization of running aggregates (SlideRow unboundedPreceding). Can you have a look at the FLIP and give feedback whether this is what you are looking for?

Re: Reducing the JIRA PR message verbosity

Sorry for late reply, but +1 too This should still provide tracking of discussion from Github PR and reduce the noise at the same time. Thanks for working on it, Max. - Henry On Fri, Sep 2, 2016 at 8:42 AM, Till Rohrmann wrote: > +1 > > On Fri, Sep 2, 2016 at 4:20 PM,

Sharing Java Collections within Flink Cluster

Hi Team, I'm working on a Flink Streaming application. The data is injected through Kafka connectors. The payload volume is roughly 100K/sec. The event payload is a string. Let's call this as DataStream1. This application also uses another DataStream, call it DataStream2, (consumes events off

Re: Yarn Test Timeout

Hi Vijay, The test fails when a NodeReport with used resources set to null is retrieved. The test assumes that a TaskManager is always exclusively running in one Yarn NodeManager which doesn't have to be true as one NodeManager can host multiple containers. The test only seems to reliably fail

[jira] [Created] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

Aljoscha Krettek created FLINK-4579: --- Summary: Add StateBackendFactory for RocksDB Backend Key: FLINK-4579 URL: https://issues.apache.org/jira/browse/FLINK-4579 Project: Flink Issue Type:

Re: Yarn Test Timeout

Hi Max, I have pulled and tested with the latest master, but I am still seeing some issues. ---Test set: