Shannon Carey created FLINK-5425:
Summary: JobManager replaced by IP in metrics
Key: FLINK-5425
URL: https://issues.apache.org/jira/browse/FLINK-5425
Project: Flink
Issue Type: Bug
Shannon Carey created FLINK-5424:
Summary: Improve Restart Strategy Logging
Key: FLINK-5424
URL: https://issues.apache.org/jira/browse/FLINK-5424
Project: Flink
Issue Type: Improvement
Fokko Driesprong created FLINK-5423:
---
Summary: Implement Stochastic Outlier Selection
Key: FLINK-5423
URL: https://issues.apache.org/jira/browse/FLINK-5423
Project: Flink
Issue Type:
Stefan Richter created FLINK-5421:
-
Summary: Explicit restore method in Snapshotable
Key: FLINK-5421
URL: https://issues.apache.org/jira/browse/FLINK-5421
Project: Flink
Issue Type:
Kostas Kloudas created FLINK-5420:
-
Summary: Make the CEP library rescalable.
Key: FLINK-5420
URL: https://issues.apache.org/jira/browse/FLINK-5420
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-5419:
---
Summary: Taskmanager metrics not accessible via REST
Key: FLINK-5419
URL: https://issues.apache.org/jira/browse/FLINK-5419
Project: Flink
Issue Type:
Timo Walther created FLINK-5418:
---
Summary: Estimated row size does not support nested types
Key: FLINK-5418
URL: https://issues.apache.org/jira/browse/FLINK-5418
Project: Flink
Issue Type: Bug
//Creating a window of ten items
/WindowedStream windowStream =
inputStream.keyBy("rackId").countWindow(10);/
// Applying a Window Function , adding some custom evaluating all the values
in the window
/DataStream inactivityStream = windowStream.apply(new