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

2016-09-05 Thread Aljoscha Krettek (JIRA)
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: B

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

2016-09-05 Thread Fabian Hueske
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? Impro

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

2016-09-05 Thread Till Rohrmann (JIRA)
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 I

Re: Yarn Test Timeout

2016-09-05 Thread Maximilian Michels
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 whe

Sharing Java Collections within Flink Cluster

2016-09-05 Thread Chakravarthy varaga
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: Reducing the JIRA PR message verbosity

2016-09-05 Thread Henry Saputra
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, Fabian Hueske wrote: >

Re: Yarn Test Timeout

2016-09-05 Thread Vijay Srinivasaraghavan
Hi Max, I have pulled and tested with the latest master, but I am still seeing some issues. ---Test set: org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase---