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---
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:
>
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
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
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
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
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
