time format for akka status

2017-01-07 Thread Alexey Demin
Hi In ExecutionGraphMessages we have code private val DATE_FORMATTER: SimpleDateFormat = new SimpleDateFormat("MM/dd/ HH:mm:ss") But sometimes it cause confusion when main logger configured with "dd/MM/". What are you thinking about making this format configurable or maybe stay only HH

[jira] [Created] (FLINK-5426) Clean up the Flink Machine Learning library

2017-01-07 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-5426: --- Summary: Clean up the Flink Machine Learning library Key: FLINK-5426 URL: https://issues.apache.org/jira/browse/FLINK-5426 Project: Flink Issue Type: I

Re: DataStream and CEP - Pattern not matching after applying a window

2017-01-07 Thread madhairsilence
Anybody?. Got kinda stuck here :( -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DataStream-and-CEP-Pattern-not-matching-after-applying-a-window-tp15164p15173.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.c