[jira] [Created] (FLINK-5425) JobManager replaced by IP in metrics

2017-01-06 Thread Shannon Carey (JIRA)
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

[jira] [Created] (FLINK-5424) Improve Restart Strategy Logging

2017-01-06 Thread Shannon Carey (JIRA)
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

[jira] [Created] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-06 Thread Fokko Driesprong (JIRA)
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:

[jira] [Created] (FLINK-5421) Explicit restore method in Snapshotable

2017-01-06 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-5420) Make the CEP library rescalable.

2017-01-06 Thread Kostas Kloudas (JIRA)
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

[jira] [Created] (FLINK-5419) Taskmanager metrics not accessible via REST

2017-01-06 Thread Chesnay Schepler (JIRA)
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:

[jira] [Created] (FLINK-5418) Estimated row size does not support nested types

2017-01-06 Thread Timo Walther (JIRA)
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

DataStream and CEP - Pattern not matching after applying a window

2017-01-06 Thread madhairsilence
//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