You are viewing a plain text version of this content. The canonical link for it is here.

---

- [GitHub] flink pull request: [FLINK-2076] [runtime] Fix memory leakage in M... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/01 01:07:25 UTC, 5 replies.
- [jira] [Commented] (FLINK-2076) Bug in re-openable hash join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 01:08:17 UTC, 5 replies.
- [GitHub] flink pull request: Fix handling of receiver and sender task failu... - posted by uce <gi...@git.apache.org> on 2015/06/01 09:18:47 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1958) Improve error handling of receiver task failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 09:26:17 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1955) Improve error handling of sender task failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 09:26:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-1958) Improve error handling of receiver task failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 09:27:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-1955) Improve error handling of sender task failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 09:27:17 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1954) Task Failures and Error Handling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 09:29:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-1941) Add documentation for Gelly-GSA - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 11:50:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2122) Make all internal streaming operators Checkpointable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/01 11:53:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2123) Fix CLI client logging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 11:59:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em... - posted by aljoscha <gi...@git.apache.org> on 2015/06/01 12:13:45 UTC, 19 replies.
- [jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 12:14:17 UTC, 23 replies.
- [GitHub] flink pull request: [FLINK-2037] Provide flink-python.jar in lib/ - posted by rmetzger <gi...@git.apache.org> on 2015/06/01 12:31:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 12:32:17 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2004] Fix memory leak in presence of fa... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/01 12:37:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 12:37:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/01 12:38:32 UTC, 32 replies.
- [jira] [Commented] (FLINK-1319) Add static code analysis for UDFs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 12:39:17 UTC, 34 replies.
- [jira] [Created] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/01 12:41:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2125) String delimiter for SocketTextStream - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/01 13:23:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2126) Scala shell tests sporadically fail on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/01 13:59:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-2120) Rename AbstractJobVertex to JobVertex - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/01 14:00:21 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/01 14:07:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2121] Fix the summation in FileInputFor... - posted by mxm <gi...@git.apache.org> on 2015/06/01 14:11:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 14:12:17 UTC, 2 replies.
- [GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw... - posted by aljoscha <gi...@git.apache.org> on 2015/06/01 14:30:00 UTC, 3 replies.
- [GitHub] flink pull request: New operator state interfaces - posted by rmetzger <gi...@git.apache.org> on 2015/06/01 14:30:48 UTC, 47 replies.
- [jira] [Assigned] (FLINK-1430) Add test for streaming scala api completeness - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/01 14:31:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/01 15:51:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 16:40:17 UTC, 6 replies.
- [jira] [Updated] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 16:40:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "terminate" signal to cleanly... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/01 16:55:07 UTC, 4 replies.
- [jira] [Commented] (FLINK-2111) Add "terminate" signal to cleanly stop streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 16:55:18 UTC, 5 replies.
- [jira] [Resolved] (FLINK-2114) PunctuationPolicy.toString() throws NullPointerException if extractor is null - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/01 16:58:17 UTC, 0 replies.
- [GitHub] flink pull request: [WIP] [FLINK-1993] [ml] - Replace MultipleLine... - posted by thvasilo <gi...@git.apache.org> on 2015/06/01 17:06:32 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1430] [streaming] Scala API completenes... - posted by mbalassi <gi...@git.apache.org> on 2015/06/01 17:07:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-1993) Replace MultipleLinearRegression's custom SGD with optimization framework's SGD - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 17:07:17 UTC, 11 replies.
- [jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 17:07:18 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/01 17:59:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2004) Memory leak in presence of failed checkpoints in KafkaSource - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/01 17:59:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/01 18:03:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/01 18:03:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-2101) Scheme Inference doesn't work for Tuple5 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/01 18:05:17 UTC, 2 replies.
- [GitHub] flink pull request: [hotfix] Remove execute() after print() in Tab... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/01 18:06:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-1727) Add decision tree to machine learning library - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/01 20:12:17 UTC, 2 replies.
- [jira] [Created] (FLINK-2128) ScalaShellITSuite failing - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 22:46:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 23:43:17 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1724) TestingCluster uses local communication with multiple task managers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 23:44:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba... - posted by uce <gi...@git.apache.org> on 2015/06/01 23:49:13 UTC, 11 replies.
- [jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/01 23:49:17 UTC, 11 replies.
- [jira] [Resolved] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 00:10:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/02 01:48:17 UTC, 0 replies.
- [jira] [Closed] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/02 01:48:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2129) User state checkpointing works only for serializable state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/02 02:38:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/02 02:46:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2098] Improvements on checkpoint-aligne... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/02 03:40:36 UTC, 3 replies.
- [jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/02 04:12:17 UTC, 36 replies.
- [jira] [Created] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/02 04:18:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/06/02 07:57:17 UTC, 17 replies.
- [GitHub] flink pull request: [FLINK-2131]: Initialization schemes for k-mea... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/06/02 08:39:06 UTC, 8 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/02 08:39:18 UTC, 13 replies.
- [jira] [Issue Comment Deleted] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/02 08:48:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/06/02 08:54:34 UTC, 31 replies.
- [jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/02 10:09:19 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2103] Expose partitionBy to user - posted by mbalassi <gi...@git.apache.org> on 2015/06/02 10:09:57 UTC, 4 replies.
- [jira] [Created] (FLINK-2132) Java version parsing is not working for OpenJDK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 10:48:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-2080) Execute Flink with sbt - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/02 10:58:17 UTC, 2 replies.
- [jira] [Updated] (FLINK-1884) Outdated Spargel docs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/02 10:58:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2132) Java version parsing is not working for OpenJDK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 11:00:44 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/02 11:17:17 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2132) Java version parsing is not working for OpenJDK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 11:25:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-2132) Java version parsing is not working for OpenJDK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 11:33:17 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2132) Java version parsing is not working for OpenJDK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 11:33:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2102] [ml] Add predict operation for La... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/02 11:43:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-2102) Add predict operation for LabeledVector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/02 11:44:17 UTC, 1 replies.
- [GitHub] flink pull request: [ml] [WIP] Consolidation of loss function - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/02 11:55:36 UTC, 1 replies.
- [GitHub] flink pull request: [ml] Rework of the optimization framework - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/02 12:01:23 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2102) Add predict operation for LabeledVector - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/02 13:26:17 UTC, 0 replies.
- [jira] [Created] (FLINK-2133) Possible deadlock in ExecutionGraph - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/02 14:34:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-2133) Possible deadlock in ExecutionGraph - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/02 14:36:17 UTC, 6 replies.
- [jira] [Created] (FLINK-2134) Deadlock in SuccessAfterNetworkBuffersFailureITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 14:40:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2128) ScalaShellITSuite failing - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 15:07:17 UTC, 0 replies.
- [jira] [Closed] (FLINK-1430) Add test for streaming scala api completeness - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/02 15:25:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/02 15:32:18 UTC, 3 replies.
- [jira] [Updated] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/02 15:57:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2069] Add flush() in CsvOutputFormat.wr... - posted by aljoscha <gi...@git.apache.org> on 2015/06/02 16:41:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2069] Fix Scala CSV Output Format - posted by aljoscha <gi...@git.apache.org> on 2015/06/02 16:43:49 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-1993] [ml] Replaces custom SGD in Multi... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/02 16:59:25 UTC, 9 replies.
- [GitHub] flink pull request: [streaming] Consolidate streaming API method n... - posted by mbalassi <gi...@git.apache.org> on 2015/06/02 17:32:18 UTC, 4 replies.
- [jira] [Created] (FLINK-2135) Java plan translation fails with ClassCastException (probably in first()) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/02 17:47:18 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2015/06/02 17:59:21 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1981] add support for GZIP files - posted by sekruse <gi...@git.apache.org> on 2015/06/02 19:04:28 UTC, 14 replies.
- [jira] [Commented] (FLINK-1981) Add GZip support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/02 19:04:51 UTC, 14 replies.
- [GitHub] flink pull request: [docs/javadoc][hotfix] Corrected Join hint and... - posted by andralungu <gi...@git.apache.org> on 2015/06/02 21:04:38 UTC, 4 replies.
- [jira] [Commented] (FLINK-2134) Deadlock in SuccessAfterNetworkBuffersFailureITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 23:56:49 UTC, 7 replies.
- [GitHub] flink pull request: [contrib] Storm compatibility - posted by mbalassi <gi...@git.apache.org> on 2015/06/03 00:40:45 UTC, 17 replies.
- [jira] [Created] (FLINK-2136) Test the streaming scala API - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 00:46:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2137) Expose partitionByHash for WindowedDataStream - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 00:49:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2138) PartitionCustom for streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 00:51:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2139) Test Streaming Outputformats - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 00:53:51 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2030) Implement an online histogram with Merging and equalization features - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/03 01:27:49 UTC, 0 replies.
- [GitHub] flink pull request: Hits - posted by mfahimazizi <gi...@git.apache.org> on 2015/06/03 01:29:39 UTC, 7 replies.
- [jira] [Assigned] (FLINK-2108) Add score function for Predictors - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/03 01:30:49 UTC, 1 replies.
- [GitHub] flink pull request: Remove extra HTML tags in TypeInformation Java... - posted by hsaputra <gi...@git.apache.org> on 2015/06/03 06:11:49 UTC, 3 replies.
- [jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/03 08:58:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-2030) Implement an online histogram with Merging and equalization features - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/03 10:17:49 UTC, 3 replies.
- [jira] [Created] (FLINK-2140) Access the number of vertices from within the GSA functions - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/03 10:32:50 UTC, 0 replies.
- [jira] [Created] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/03 10:47:49 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 11:08:49 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1993) Replace MultipleLinearRegression's custom SGD with optimization framework's SGD - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/03 11:13:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2130] [streaming] RMQ Source properly p... - posted by mbalassi <gi...@git.apache.org> on 2015/06/03 11:18:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-2137) Expose partitionByHash for WindowedDataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/03 11:19:50 UTC, 1 replies.
- [jira] [Closed] (FLINK-2137) Expose partitionByHash for WindowedDataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/03 11:32:50 UTC, 0 replies.
- [jira] [Created] (FLINK-2142) GSoC project: Exact and Approximate Statistics for Data Streams and Windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:36:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:41:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-2142) GSoC project: Exact and Approximate Statistics for Data Streams and Windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:42:50 UTC, 0 replies.
- [jira] [Created] (FLINK-2144) Implement count, average, and variance for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:48:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1526][gelly] [work in progress] Added M... - posted by vasia <gi...@git.apache.org> on 2015/06/03 11:49:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 11:50:49 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2136) Test the streaming scala API - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/06/03 11:50:50 UTC, 0 replies.
- [jira] [Created] (FLINK-2145) Median calculation for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:51:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-2145) Median calculation for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:52:49 UTC, 1 replies.
- [jira] [Updated] (FLINK-2144) Implement count, average, and variance for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:52:49 UTC, 2 replies.
- [jira] [Created] (FLINK-2146) Fast calculation of min/max with arbitrary eviction and triggers - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 11:56:50 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe... - posted by vasia <gi...@git.apache.org> on 2015/06/03 11:58:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 11:58:49 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1707][WIP]Add an Affinity Propagation L... - posted by vasia <gi...@git.apache.org> on 2015/06/03 12:00:18 UTC, 3 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 12:00:50 UTC, 2 replies.
- [jira] [Created] (FLINK-2147) Approximate calculation of frequencies in data streams - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 12:07:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/03 12:10:49 UTC, 57 replies.
- [jira] [Created] (FLINK-2148) Approximately calculate the number of distinct elements of a stream - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 12:13:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-2147) Approximate calculation of frequencies in data streams - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/03 12:13:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-1962) Add Gelly Scala API - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2015/06/03 12:21:49 UTC, 12 replies.
- [jira] [Commented] (FLINK-2048) Enhance Twitter Stream support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 12:22:50 UTC, 0 replies.
- [jira] [Created] (FLINK-2149) Simplify Gelly Jaccard similarity example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/03 12:29:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-1759) Execution statistics for vertex-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/03 12:30:49 UTC, 1 replies.
- [jira] [Updated] (FLINK-2149) Simplify Gelly Jaccard similarity example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/03 12:41:49 UTC, 1 replies.
- [jira] [Created] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/03 12:48:56 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2149) Simplify Gelly Jaccard similarity example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/03 15:15:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 15:16:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-2103) Expose partitionBy to the user in Stream API - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 15:17:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 15:17:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-2142) GSoC project: Exact and Approximate Statistics for Data Streams and Windows - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 15:19:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2126] Fixed Flink scala shell ITSuite s... - posted by nikste <gi...@git.apache.org> on 2015/06/03 15:31:37 UTC, 7 replies.
- [jira] [Commented] (FLINK-2126) Scala shell tests sporadically fail on travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 15:31:38 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2135] Fix faulty cast to GroupReduceFun... - posted by rmetzger <gi...@git.apache.org> on 2015/06/03 16:07:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-2135) Java plan translation fails with ClassCastException (probably in first()) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 16:07:39 UTC, 3 replies.
- [jira] [Created] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 16:11:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2149][gelly] Simplified Jaccard Example - posted by andralungu <gi...@git.apache.org> on 2015/06/03 16:16:36 UTC, 5 replies.
- [jira] [Commented] (FLINK-2149) Simplify Gelly Jaccard similarity example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 16:16:38 UTC, 5 replies.
- [jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/03 16:31:38 UTC, 21 replies.
- [jira] [Updated] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/03 16:32:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2153) Exclude dependency on hbase annotations module - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 16:47:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2116) Make pipeline extension require less coding - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/03 16:49:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2139) Test Streaming Outputformats - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 16:56:38 UTC, 0 replies.
- [GitHub] flink pull request: [wip] [FLINK-2136] Adding DataStream tests for... - posted by gaborhermann <gi...@git.apache.org> on 2015/06/03 16:59:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-2136) Test the streaming scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 16:59:38 UTC, 16 replies.
- [GitHub] flink pull request: [FLINK-2116] [ml] Reusing predict operation fo... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/03 17:03:32 UTC, 7 replies.
- [jira] [Commented] (FLINK-2116) Make pipeline extension require less coding - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 17:03:38 UTC, 12 replies.
- [jira] [Assigned] (FLINK-2153) Exclude dependency on hbase annotations module - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 17:07:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-2153) Exclude dependency on hbase annotations module - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 17:08:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2134] Close Netty channel via CloseRequ... - posted by uce <gi...@git.apache.org> on 2015/06/03 18:53:16 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2095) Screenshots missing in webcient documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 19:15:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1674) Add test with nested avro type - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 19:18:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1947) Make Avro and Tachyon test logging less verbose - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 19:22:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-2075) Shade akka and protobuf dependencies away - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 19:23:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-2075) Shade akka and protobuf dependencies away - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/03 19:23:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2092] Adjust documentation for print()/... - posted by rmetzger <gi...@git.apache.org> on 2015/06/03 20:10:23 UTC, 12 replies.
- [jira] [Commented] (FLINK-2092) Document (new) behavior of print() and execute() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/03 20:10:39 UTC, 12 replies.
- [jira] [Created] (FLINK-2154) ActiveTriggerPolicy collects elements to a closed buffer after job finishes - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/03 22:12:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Lokesh Rajaram (JIRA)" <ji...@apache.org> on 2015/06/03 22:16:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/03 22:21:39 UTC, 14 replies.
- [jira] [Commented] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/03 23:47:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 02:16:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 02:16:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1907) Scala Interactive Shell - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 02:17:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1907) Scala Interactive Shell - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 02:17:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Lokesh Rajaram (JIRA)" <ji...@apache.org> on 2015/06/04 06:03:38 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Lokesh Rajaram (JIRA)" <ji...@apache.org> on 2015/06/04 08:38:41 UTC, 1 replies.
- [GitHub] flink pull request: Enforce import restriction on usage of Flink s... - posted by lokeshrajaram <gi...@git.apache.org> on 2015/06/04 09:00:59 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2048) Enhance Twitter Stream support - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/06/04 09:13:39 UTC, 0 replies.
- [jira] [Created] (FLINK-2156) Scala modules cannot create logging file - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 10:03:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-2156) Scala modules cannot create logging file - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 10:04:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa... - posted by lokeshrajaram <gi...@git.apache.org> on 2015/06/04 10:17:33 UTC, 9 replies.
- [GitHub] flink pull request: [streaming] ITCases for streaming scala exampl... - posted by mbalassi <gi...@git.apache.org> on 2015/06/04 10:26:14 UTC, 2 replies.
- [jira] [Created] (FLINK-2157) Create evaluation framework for ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 11:10:39 UTC, 0 replies.
- [jira] [Created] (FLINK-2158) NullPointerException in DateSerializer. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 11:15:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2134) Deadlock in SuccessAfterNetworkBuffersFailureITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/04 11:18:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2159) SimpleRecoveryITCase fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/04 11:29:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/04 11:38:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel() - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/04 11:47:38 UTC, 11 replies.
- [jira] [Created] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 12:00:38 UTC, 0 replies.
- [GitHub] flink pull request: From stream to Hbase - posted by StephanEwen <gi...@git.apache.org> on 2015/06/04 12:43:24 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/04 12:56:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 12:57:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2135) Java plan translation fails with ClassCastException (probably in first()) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 13:17:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2095) Screenshots missing in webcient documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 13:28:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-2095) Screenshots missing in webcient documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 13:28:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2076) Bug in re-openable hash join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 13:29:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2126) Scala shell tests sporadically fail on travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 13:30:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-2126) Scala shell tests sporadically fail on travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 13:30:40 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption... - posted by fhueske <gi...@git.apache.org> on 2015/06/04 13:36:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 13:36:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2162) Implement adaptive learning rate strategies for SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 13:43:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-2162) Implement adaptive learning rate strategies for SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 13:44:38 UTC, 1 replies.
- [GitHub] flink pull request: Add CONTRIBUTING.md file with pointers to our ... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 13:51:19 UTC, 3 replies.
- [jira] [Closed] (FLINK-1993) Replace MultipleLinearRegression's custom SGD with optimization framework's SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/04 14:05:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 14:08:51 UTC, 14 replies.
- [jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 14:09:38 UTC, 14 replies.
- [jira] [Assigned] (FLINK-2140) Access the number of vertices from within the GSA functions - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/04 14:14:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2140][gelly] Allowed access to the numb... - posted by andralungu <gi...@git.apache.org> on 2015/06/04 14:17:23 UTC, 3 replies.
- [jira] [Commented] (FLINK-2140) Access the number of vertices from within the GSA functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 14:17:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-2024) Table API mentioned only in Batch in documentation site - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 14:39:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2123) Fix CLI client logging - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 14:46:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2159) SimpleRecoveryITCase fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 14:56:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2136] Adding DataStream tests for Scala... - posted by gaborhermann <gi...@git.apache.org> on 2015/06/04 15:42:21 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-2158] Add support for null to the DateS... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 15:52:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-2158) NullPointerException in DateSerializer. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 15:53:38 UTC, 2 replies.
- [jira] [Created] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/04 15:58:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1565][FLINK-2078] Document ExecutionCon... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 16:12:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-1565) Document object reuse behavior - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 16:13:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-2123) Fix CLI client logging - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 16:15:38 UTC, 7 replies.
- [jira] [Commented] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/04 16:45:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-1844) Add Normaliser to ML library - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/04 17:08:38 UTC, 23 replies.
- [jira] [Commented] (FLINK-2000) Add SQL-style aggregations for Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 17:23:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2000] [table] Add sql style aggregation... - posted by chhao01 <gi...@git.apache.org> on 2015/06/04 17:23:40 UTC, 4 replies.
- [jira] [Commented] (FLINK-2156) Scala modules cannot create logging file - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/04 18:08:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2123] Fix log4j warnings on CliFrontend... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 18:20:02 UTC, 5 replies.
- [jira] [Resolved] (FLINK-864) Add description of mutable object iterators (GroupReduce, CoGroup) to documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 18:41:42 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1061] Document how to run an example - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 18:51:17 UTC, 4 replies.
- [jira] [Commented] (FLINK-1061) Describe how to run the examples from the command line - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 18:51:38 UTC, 4 replies.
- [jira] [Assigned] (FLINK-1061) Describe how to run the examples from the command line - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 18:51:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/04 18:54:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2160] Change Streaming Source Interface... - posted by aljoscha <gi...@git.apache.org> on 2015/06/04 18:55:15 UTC, 8 replies.
- [jira] [Assigned] (FLINK-1126) Add suggestion for using large TupleX types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 18:57:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1126][docs] Best practice: named TupleX... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 19:32:57 UTC, 4 replies.
- [jira] [Commented] (FLINK-1126) Add suggestion for using large TupleX types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 19:33:40 UTC, 4 replies.
- [jira] [Assigned] (FLINK-1565) Document object reuse behavior - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 19:33:41 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1422) Missing usage example for "withParameters" - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 19:37:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2080) Execute Flink with sbt - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 20:04:38 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-2080) Execute Flink with sbt - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 20:05:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2080] Document how to use Flink with sb... - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 20:06:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/04 20:13:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2087] Add streaming mode switch to YARN - posted by rmetzger <gi...@git.apache.org> on 2015/06/04 22:27:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-2087) Add streaming mode to YARN as well - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 22:28:38 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2139] [streaming] Streaming outputforma... - posted by mbalassi <gi...@git.apache.org> on 2015/06/04 22:55:09 UTC, 7 replies.
- [jira] [Commented] (FLINK-2139) Test Streaming Outputformats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/04 22:55:38 UTC, 7 replies.
- [jira] [Resolved] (FLINK-2123) Fix CLI client logging - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/05 10:16:00 UTC, 0 replies.
- [GitHub] flink pull request: Added member currentSplit for FileInputFormat.... - posted by peedeeX21 <gi...@git.apache.org> on 2015/06/05 10:43:04 UTC, 7 replies.
- [jira] [Commented] (FLINK-2002) Iterative test fails when ran with other tests in the same environment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 11:01:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-1940) StockPrice example cannot be visualized - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 11:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-1892) Local job execution does not exit. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 11:13:00 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2072] [ml] [docs] Add a quickstart guid... - posted by thvasilo <gi...@git.apache.org> on 2015/06/05 11:14:27 UTC, 65 replies.
- [jira] [Commented] (FLINK-2072) Add a quickstart guide for FlinkML - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 11:15:00 UTC, 65 replies.
- [jira] [Commented] (FLINK-1863) RemoteInputChannelTest.testConcurrentOnBufferAndRelease fails on travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 11:16:00 UTC, 1 replies.
- [GitHub] flink pull request: - posted by thvasilo <gi...@git.apache.org> on 2015/06/05 11:16:57 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 11:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2153) Exclude dependency on hbase annotations module - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 11:22:00 UTC, 8 replies.
- [jira] [Assigned] (FLINK-2002) Iterative test fails when ran with other tests in the same environment - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/05 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2164) Document batch and streaming startup modes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/05 11:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1892) Local job execution does not exit. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/05 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2165) Rename Table conversion methods in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2167) Add fromHCat() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:54:12 UTC, 0 replies.
- [jira] [Created] (FLINK-2169) Add fromParquet() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:54:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2170) Add fromOrcFile() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2165) Rename Table conversion methods in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 11:56:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2165] [TableAPI] Renamed table conversi... - posted by fhueske <gi...@git.apache.org> on 2015/06/05 12:18:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-2165) Rename Table conversion methods in TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 12:19:00 UTC, 2 replies.
- [jira] [Created] (FLINK-2171) Add instruction to build Flink with Scala 2.11 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 12:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2065) Cancelled jobs finish with final state FAILED - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/05 13:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1892) Local job execution does not exit. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 13:53:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-1892) Local job execution does not exit. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 13:53:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/05 15:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2165) Rename Table conversion methods in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/05 15:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1635) Remove Apache Thrift dependency from Flink - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/05 15:57:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1635] remove Apache Thrift and Google P... - posted by mxm <gi...@git.apache.org> on 2015/06/05 17:03:48 UTC, 8 replies.
- [jira] [Commented] (FLINK-1635) Remove Apache Thrift dependency from Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 17:04:01 UTC, 8 replies.
- [jira] [Created] (FLINK-2172) Stabilize SocketOutputFormatTest - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/05 18:11:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2173) Python used diffente tmp file than Flink - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 18:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2173) Python used different tmp file than Flink - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 18:22:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-2173) Python uses different tmp file than Flink - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 18:22:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-2173) Python uses different tmp file than Flink - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/06/05 18:46:00 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2164] Document streaming and batch mode - posted by rmetzger <gi...@git.apache.org> on 2015/06/05 18:59:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-2164) Document batch and streaming startup modes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 19:00:04 UTC, 4 replies.
- [jira] [Created] (FLINK-2174) Allow comments in 'slaves' file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 19:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1565) Document object reuse behavior - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/05 19:16:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1126) Add suggestion for using large TupleX types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/05 19:17:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2078) Document type registration at the ExecutionEnvironment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/05 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2175) Allow multiple jobs in single jar file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 19:24:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2176) Add support for ProgramDesctiption interface in clients - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 19:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2176) Add support for ProgramDesctiption interface in clients - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 19:44:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-2068) WebUI support multiple jobs per jar file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/05 20:19:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2174] Allow comments in 'slaves' file - posted by mjsax <gi...@git.apache.org> on 2015/06/05 20:43:15 UTC, 21 replies.
- [jira] [Commented] (FLINK-2174) Allow comments in 'slaves' file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 20:44:00 UTC, 21 replies.
- [jira] [Created] (FLINK-2177) NillPointer in task resource release - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 22:58:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-2177) NillPointer in task resource release - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 23:00:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2177) NullPointer in task resource release - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 23:01:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2133] [jobmanager] Fix possible deadloc... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/05 23:07:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2133) Possible deadlock in ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 23:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2133) Possible deadlock in ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/05 23:26:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo... - posted by StephanEwen <gi...@git.apache.org> on 2015/06/05 23:34:09 UTC, 6 replies.
- [jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 23:35:00 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2175] Allow multiple jobs in single jar... - posted by mjsax <gi...@git.apache.org> on 2015/06/05 23:40:55 UTC, 5 replies.
- [jira] [Commented] (FLINK-2175) Allow multiple jobs in single jar file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/05 23:41:02 UTC, 5 replies.
- [jira] [Updated] (FLINK-2174) Allow comments in 'slaves' file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/06 00:14:01 UTC, 1 replies.
- [GitHub] flink pull request: [Flink 1844] Add Normaliser to ML library - posted by fobeligi <gi...@git.apache.org> on 2015/06/06 00:25:59 UTC, 12 replies.
- [jira] [Created] (FLINK-2178) groupReduceOnNeighbors throws NoSuchElementException - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/06 13:00:03 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2178][gelly] Fixed groupReduceOnNeighbo... - posted by andralungu <gi...@git.apache.org> on 2015/06/06 13:07:51 UTC, 10 replies.
- [jira] [Commented] (FLINK-2178) groupReduceOnNeighbors throws NoSuchElementException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/06 13:08:00 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-2153] Exclude Hbase annotations - posted by mbalassi <gi...@git.apache.org> on 2015/06/06 13:55:27 UTC, 3 replies.
- [jira] [Closed] (FLINK-2139) Test Streaming Outputformats - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/06 17:51:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/06 21:48:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/07 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2179) when return value from linkedlist or map and use in filter function display error - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/06/07 15:18:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2150][gelly] Added library method for a... - posted by andralungu <gi...@git.apache.org> on 2015/06/07 15:39:24 UTC, 16 replies.
- [jira] [Closed] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/07 22:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2180) Streaming iterate test fails spuriously - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/07 22:37:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2164) Document batch and streaming startup modes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/07 23:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1061) Describe how to run the examples from the command line - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/07 23:55:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2092) Document (new) behavior of print() and execute() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/07 23:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2179) when return value from linkedlist or map and use in filter function display error - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/08 00:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-1858) Add further checks to QA bot - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/08 00:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2087) Add streaming mode to YARN as well - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/08 01:00:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2177) NullPointer in task resource release - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/08 07:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2181) SessionWindowing example has a memleak - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/08 09:43:03 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/06/08 10:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/08 10:40:01 UTC, 18 replies.
- [jira] [Assigned] (FLINK-2180) Streaming iterate test fails spuriously - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/06/08 10:42:00 UTC, 0 replies.
- [GitHub] flink pull request: [wip] [FLINK-2180] [streaming] Iteration test ... - posted by gaborhermann <gi...@git.apache.org> on 2015/06/08 10:47:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/08 10:48:00 UTC, 8 replies.
- [jira] [Closed] (FLINK-2080) Execute Flink with sbt - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/08 11:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2153) Exclude dependency on hbase annotations module - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/08 11:18:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1635) Remove Apache Thrift dependency from Flink - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/08 11:22:01 UTC, 0 replies.
- [GitHub] flink pull request: Clean up naming of State/Checkpoint Interfaces - posted by mbalassi <gi...@git.apache.org> on 2015/06/08 11:23:44 UTC, 3 replies.
- [jira] [Updated] (FLINK-1685) Document how to read gzip/compressed files with Flink - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/08 11:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-1981) Add GZip support - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/08 11:27:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1685) Document how to read gzip/compressed files with Flink - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/08 11:27:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2054] Add object-reuse switch for strea... - posted by aljoscha <gi...@git.apache.org> on 2015/06/08 11:36:50 UTC, 6 replies.
- [jira] [Commented] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/08 11:37:00 UTC, 6 replies.
- [jira] [Created] (FLINK-2182) Add stateful Streaming Sequence Source - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/08 12:13:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2182] Add stateful Streaming Sequence S... - posted by aljoscha <gi...@git.apache.org> on 2015/06/08 12:51:50 UTC, 10 replies.
- [jira] [Commented] (FLINK-2182) Add stateful Streaming Sequence Source - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/08 12:52:01 UTC, 10 replies.
- [jira] [Created] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/08 14:05:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2161] modified Scala shell start script... - posted by nikste <gi...@git.apache.org> on 2015/06/08 14:05:37 UTC, 14 replies.
- [GitHub] flink pull request: [docs] Fix some typos and grammar in the Strea... - posted by ggevay <gi...@git.apache.org> on 2015/06/08 14:35:02 UTC, 2 replies.
- [jira] [Commented] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/08 14:48:00 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-1844] [ml] Add Normaliser to ML library - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/08 14:52:46 UTC, 18 replies.
- [jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class - posted by "Shivani Ghatge (JIRA)" <ji...@apache.org> on 2015/06/08 14:53:00 UTC, 36 replies.
- [jira] [Updated] (FLINK-2093) Add a difference method to Gelly's Graph class - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/08 15:13:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-2000) Add SQL-style aggregations for Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/08 16:00:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/08 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2184) Cannot get last element with maxBy/minBy - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/06/08 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2185) Rework semantics for .setSeed function of SVM - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/08 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2186) Reworj SVM import to support very wide files - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/08 16:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2186) Rework SVM import to support very wide files - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/08 16:53:01 UTC, 3 replies.
- [jira] [Updated] (FLINK-2185) Rework semantics for .setSeed function of SVM - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/08 16:54:03 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2093][gelly] Added difference method - posted by shghatge <gi...@git.apache.org> on 2015/06/08 17:07:10 UTC, 12 replies.
- [jira] [Commented] (FLINK-1877) Stalled Flink on Tez build - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/08 17:21:01 UTC, 2 replies.
- [jira] [Updated] (FLINK-1877) Stalled Flink on Tez build - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/08 18:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2174) Allow comments in 'slaves' file - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/08 19:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1916) EOFException when running delta-iteration job - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/08 19:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2187) KMeans clustering is not present in release-0.9-rc1 - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/08 21:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2187) KMeans clustering is not present in release-0.9-rc1 - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/08 21:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/08 23:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2185) Rework semantics for .setSeed function of SVM - posted by "Dmitriy Lyubimov (JIRA)" <ji...@apache.org> on 2015/06/08 23:42:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/09 08:41:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2187) KMeans clustering is not present in release-0.9-rc1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/09 09:57:00 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1844) Add Normaliser to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/09 10:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2187) KMeans clustering is not present in release-0.9-rc1 - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/09 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2188) Reading from big HBase Tables - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/06/09 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2189) NullPointerException in MutableHashTable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/09 11:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2189) NullPointerException in MutableHashTable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/09 11:51:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2188) Reading from big HBase Tables - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/09 13:06:00 UTC, 9 replies.
- [jira] [Updated] (FLINK-2188) Reading from big HBase Tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/09 13:55:00 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API - posted by PieterJanVanAeken <gi...@git.apache.org> on 2015/06/09 14:48:57 UTC, 9 replies.
- [jira] [Created] (FLINK-2190) Enhance stream decoration/compression extensibility - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/06/09 14:49:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2188) Reading from big HBase Tables - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/09 14:50:01 UTC, 1 replies.
- [GitHub] flink pull request: Fixed a few trivial issues: - posted by ggevay <gi...@git.apache.org> on 2015/06/09 15:29:31 UTC, 0 replies.
- [jira] [Created] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/09 15:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/09 15:46:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/09 15:54:02 UTC, 8 replies.
- [GitHub] flink pull request: [streaming] Optional iteration feedback partit... - posted by gyfora <gi...@git.apache.org> on 2015/06/09 17:25:04 UTC, 2 replies.
- [GitHub] flink pull request: [release-0.9] Fixed a few trivial issues: - posted by ggevay <gi...@git.apache.org> on 2015/06/09 17:31:13 UTC, 3 replies.
- [GitHub] flink pull request: [scripts] cleanup release script and make it m... - posted by mxm <gi...@git.apache.org> on 2015/06/09 17:50:47 UTC, 11 replies.
- [jira] [Closed] (FLINK-2182) Add stateful Streaming Sequence Source - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/09 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/09 20:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/09 20:44:00 UTC, 2 replies.
- [GitHub] flink pull request: [streaming] Allow force-enabling checkpoints f... - posted by gyfora <gi...@git.apache.org> on 2015/06/09 23:40:37 UTC, 6 replies.
- [GitHub] flink pull request: Flink Storm compatibility - posted by mjsax <gi...@git.apache.org> on 2015/06/10 02:15:14 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c... - posted by aljoscha <gi...@git.apache.org> on 2015/06/10 08:53:31 UTC, 7 replies.
- [jira] [Created] (FLINK-2193) Partial shuffling - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/06/10 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2194) Type extractor does not support Writable type - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/10 09:39:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2194] [type extractor] Treats Writable ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/10 09:41:27 UTC, 9 replies.
- [jira] [Commented] (FLINK-2194) Type extractor does not support Writable type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/10 09:42:00 UTC, 9 replies.
- [jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2015/06/10 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2195) Set Configuration for Configurable Hadoop InputFormats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/10 10:42:00 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Bring KMeansDataGenerator and KMeans ... - posted by aljoscha <gi...@git.apache.org> on 2015/06/10 11:00:42 UTC, 2 replies.
- [jira] [Created] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 11:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2194) Type extractor does not support Writable type - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/10 11:15:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/10 11:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2194) Type extractor does not support Writable type - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/10 11:17:00 UTC, 0 replies.
- [GitHub] flink pull request: [streaming] Fixed streaming example jars packa... - posted by mbalassi <gi...@git.apache.org> on 2015/06/10 11:42:30 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2196] [javaAPI] Moved misplaced SortPar... - posted by fhueske <gi...@git.apache.org> on 2015/06/10 12:02:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/10 12:03:00 UTC, 1 replies.
- [jira] [Created] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/10 12:05:00 UTC, 0 replies.
- [GitHub] flink pull request: [release-0.9] [streaming] Fixed streaming exam... - posted by fhueske <gi...@git.apache.org> on 2015/06/10 12:33:24 UTC, 4 replies.
- [jira] [Created] (FLINK-2198) Build fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 12:57:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method - posted by shghatge <gi...@git.apache.org> on 2015/06/10 13:25:48 UTC, 21 replies.
- [jira] [Created] (FLINK-2199) Build with skipped tests fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 13:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1520) Read edges and vertices from CSV files - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/10 14:37:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2099) Add a SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/10 14:50:00 UTC, 2 replies.
- [GitHub] flink pull request: [release-0.9] [runtime] Logging update for che... - posted by mbalassi <gi...@git.apache.org> on 2015/06/10 14:52:09 UTC, 0 replies.
- [GitHub] flink pull request: [streaming] Fast calculation of medians of win... - posted by ggevay <gi...@git.apache.org> on 2015/06/10 14:52:33 UTC, 7 replies.
- [jira] [Commented] (FLINK-2145) Median calculation for windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/10 14:53:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "Philipp Götze (JIRA)" <ji...@apache.org> on 2015/06/10 15:46:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/06/10 15:51:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/06/10 15:52:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2199) Build with skipped tests fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 15:57:00 UTC, 0 replies.
- [GitHub] flink pull request: [build] [streaming] Streaming parent's depende... - posted by mbalassi <gi...@git.apache.org> on 2015/06/10 16:12:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-2198) Build fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2201) Inconsistent use of ClosureCleaner in streaming window helpers - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/10 17:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/10 17:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2202) Calling distinct() requires tuple input - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/10 17:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2202) Calling distinct() requires tuple input - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/10 17:50:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2199] Escape UTF characters in Scala Sh... - posted by fhueske <gi...@git.apache.org> on 2015/06/10 17:51:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-2199) Build with skipped tests fails on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/10 17:52:01 UTC, 2 replies.
- [GitHub] flink pull request: [scripts] remove quickstart scripts - posted by mxm <gi...@git.apache.org> on 2015/06/10 18:25:40 UTC, 6 replies.
- [GitHub] flink pull request: FLINK-1732 Gaussian Mixture Model for Flink-ml... - posted by shakir774 <gi...@git.apache.org> on 2015/06/10 23:02:31 UTC, 4 replies.
- [jira] [Commented] (FLINK-1732) Add Gaussian mixture model to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/10 23:03:01 UTC, 4 replies.
- [jira] [Created] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/11 08:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/11 09:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/11 09:44:00 UTC, 17 replies.
- [jira] [Assigned] (FLINK-2167) Add fromHCat() to TableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/11 10:19:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/11 10:21:00 UTC, 8 replies.
- [jira] [Updated] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/11 11:34:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2072) Add a quickstart guide for FlinkML - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/11 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/11 11:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2198) BlobManager tests fail on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/11 12:00:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/11 12:00:02 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2198) BlobManager tests fail on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/11 12:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2199) Build with skipped tests fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/11 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/11 12:33:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/11 12:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/11 12:40:00 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2183][runtime] fix deadlock for concurr... - posted by mxm <gi...@git.apache.org> on 2015/06/11 14:00:21 UTC, 2 replies.
- [GitHub] flink pull request: [streaming] Minor DataStream cleanups - posted by mbalassi <gi...@git.apache.org> on 2015/06/11 15:05:28 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/11 17:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-2207) Online documentation of Table API is out of date - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/11 17:06:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-2208) Build error for IBM Java - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/06/12 01:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-2208) Built error for IBM Java - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/06/12 01:00:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-2208) Build error for Java IBM - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/06/12 01:01:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2206] Fix incorrect counts of finished,... - posted by fhueske <gi...@git.apache.org> on 2015/06/12 02:09:40 UTC, 3 replies.
- [jira] [Commented] (FLINK-2207) Online documentation of Table API is out of date - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/12 02:12:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2207) Online documentation of Table API is out of date - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/12 02:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/12 02:12:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Shiti Saxena (JIRA)" <ji...@apache.org> on 2015/06/12 06:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2198) BlobManager tests fail on Windows - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/12 09:31:00 UTC, 2 replies.
- [GitHub] flink pull request: [release-0.9] [streaming] Logging update for c... - posted by mxm <gi...@git.apache.org> on 2015/06/12 09:45:53 UTC, 1 replies.
- [jira] [Created] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/12 09:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/12 10:15:00 UTC, 21 replies.
- [jira] [Closed] (FLINK-2174) Allow comments in 'slaves' file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/12 11:03:00 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2195] Configure Configurable Hadoop Inp... - posted by uce <gi...@git.apache.org> on 2015/06/12 11:19:33 UTC, 4 replies.
- [jira] [Commented] (FLINK-2195) Set Configuration for Configurable Hadoop InputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/12 11:20:00 UTC, 9 replies.
- [GitHub] flink pull request: [release-0.9] [FLINK-2195] Configure Configura... - posted by uce <gi...@git.apache.org> on 2015/06/12 11:22:40 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2188) Reading from big HBase Tables - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/12 11:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2195) Set Configuration for Configurable Hadoop InputFormats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/12 11:57:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2207] Fix TableAPI conversion documenat... - posted by fhueske <gi...@git.apache.org> on 2015/06/12 12:30:13 UTC, 4 replies.
- [jira] [Closed] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/12 12:38:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/12 14:11:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-2207) Online documentation of Table API is out of date - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/12 14:33:00 UTC, 0 replies.
- [GitHub] flink pull request: [legal] Updates LICENSE/NOTICE file of source ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/12 18:10:29 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-2203] handling null values for RowSeria... - posted by Shiti <gi...@git.apache.org> on 2015/06/12 21:04:30 UTC, 12 replies.
- [jira] [Assigned] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/13 08:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2208) Build error for Java IBM - posted by "Johannes Günther (JIRA)" <ji...@apache.org> on 2015/06/13 16:12:00 UTC, 5 replies.
- [jira] [Closed] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/13 21:14:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie... - posted by mjsax <gi...@git.apache.org> on 2015/06/14 00:16:37 UTC, 3 replies.
- [jira] [Commented] (FLINK-1818) Provide API to cancel running job - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/14 00:17:00 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2152] Added zipWithIndex - posted by andralungu <gi...@git.apache.org> on 2015/06/14 00:24:21 UTC, 33 replies.
- [jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/14 00:25:00 UTC, 33 replies.
- [jira] [Comment Edited] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/14 00:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2210) Compute aggregations by ignoring null values - posted by "Shiti Saxena (JIRA)" <ji...@apache.org> on 2015/06/14 12:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2210) Table API aggregate by ignoring null values - posted by "Shiti Saxena (JIRA)" <ji...@apache.org> on 2015/06/14 12:46:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2208) Build error for Java IBM - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/06/14 13:45:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2208] Fix IBM Java integration bug - posted by FelixNeutatz <gi...@git.apache.org> on 2015/06/14 16:47:18 UTC, 3 replies.
- [jira] [Created] (FLINK-2211) Generalize ALS API - posted by "Ronny Bräunlich (JIRA)" <ji...@apache.org> on 2015/06/14 19:05:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2211) Generalize ALS API - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/06/14 19:07:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2210] Table API support for aggregation... - posted by Shiti <gi...@git.apache.org> on 2015/06/14 21:05:01 UTC, 18 replies.
- [jira] [Commented] (FLINK-2210) Table API aggregate by ignoring null values - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/14 21:05:02 UTC, 18 replies.
- [jira] [Closed] (FLINK-2002) Iterative test fails when ran with other tests in the same environment - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/14 22:17:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2209] Document linking with jars not in... - posted by mbalassi <gi...@git.apache.org> on 2015/06/14 22:29:58 UTC, 15 replies.
- [jira] [Commented] (FLINK-2211) Generalize ALS API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 10:42:05 UTC, 6 replies.
- [jira] [Created] (FLINK-2212) Exit code on failed job - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2213) Configure number of vcores - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 11:31:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-1579) Create a Flink History Server - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 11:33:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2214) ALS predict and empiricalRisk function can cause hash join function to exceed maximum number of recursions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 12:03:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2212) Exit code on failed job - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/15 12:13:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2214] [ml] Adds join hints to ALS to av... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/15 12:15:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-2214) ALS predict and empiricalRisk function can cause hash join function to exceed maximum number of recursions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/15 12:16:00 UTC, 6 replies.
- [jira] [Created] (FLINK-2215) Document how to use the HCatInputFormat - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/06/15 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2216) Examples directory contains `flink-java-examples-0.9.0-javadoc.jar` - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 12:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2216) Examples directory contains `flink-java-examples-0.9.0-javadoc.jar` - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 13:00:09 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2216) Examples directory contains `flink-java-examples-0.9.0-javadoc.jar` - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 13:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2212) Exit code on failed job - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/15 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2217) Web client does not remove uploaded JARs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 14:34:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2217) Web client does not remove uploaded JARs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/15 14:38:00 UTC, 6 replies.
- [jira] [Created] (FLINK-2218) Web client cannot specify parallelism - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 14:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2218) Web client cannot specify parallelism - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/15 14:57:00 UTC, 12 replies.
- [jira] [Created] (FLINK-2219) JobManagerInfoServlet IllegalArgumentException when pressing state button - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 15:20:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2219) JobManagerInfoServlet IllegalArgumentException when pressing state button - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 15:20:02 UTC, 0 replies.
- [jira] [Created] (FLINK-2220) Join on Pojo without hashCode() silently fails - posted by "Marcus Leich (JIRA)" <ji...@apache.org> on 2015/06/15 15:22:00 UTC, 0 replies.
- [GitHub] flink pull request: [build] Merge transitive notice files to shade... - posted by mbalassi <gi...@git.apache.org> on 2015/06/15 15:25:50 UTC, 4 replies.
- [jira] [Created] (FLINK-2221) Checkpoints to "file://" are not cleaned up - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/15 15:43:03 UTC, 0 replies.
- [jira] [Created] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 15:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 15:46:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/15 15:51:01 UTC, 16 replies.
- [jira] [Created] (FLINK-2223) Web frontend shows wrong accumulator results for latest job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 16:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails - posted by "Marcus Leich (JIRA)" <ji...@apache.org> on 2015/06/15 16:19:00 UTC, 4 replies.
- [jira] [Created] (FLINK-2224) JobManager log does not contain root cause and stack trace of exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 16:39:02 UTC, 0 replies.
- [GitHub] flink pull request: [YARN] fail container on failed single job clu... - posted by mxm <gi...@git.apache.org> on 2015/06/15 16:47:45 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-2221) Checkpoints to "file://" are not cleaned up - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/15 16:48:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2120) Rename AbstractJobVertex to JobVertex - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/15 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2225) Erroneous scheduling of co-located tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 16:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2225) Erroneous scheduling of co-located tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/15 16:55:00 UTC, 2 replies.
- [jira] [Created] (FLINK-2226) Fail YARN application on failed single-job YARN cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/15 17:00:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-2224) JobManager log does not contain root cause and stack trace of exceptions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 17:00:02 UTC, 1 replies.
- [jira] [Closed] (FLINK-2212) Exit code on failed job - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/15 17:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2226) Fail YARN application on failed single-job YARN cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/15 17:04:01 UTC, 5 replies.
- [jira] [Resolved] (FLINK-2224) JobManager log does not contain root cause and stack trace of exceptions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 17:25:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2227) .yarn-properties file is not cleaned up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 17:38:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2227) .yarn-properties file is not cleaned up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/15 17:42:00 UTC, 2 replies.
- [jira] [Created] (FLINK-2228) Web fronted uses two different timezones when reporting the time for job - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/15 18:19:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-2228) Web fronted uses two different timezones when reporting the time for job - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/15 18:21:01 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2226][YARN] fail container on failed si... - posted by mxm <gi...@git.apache.org> on 2015/06/15 18:32:16 UTC, 3 replies.
- [jira] [Updated] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/15 18:54:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2221] [docs] Docs for not using local f... - posted by mbalassi <gi...@git.apache.org> on 2015/06/15 18:56:01 UTC, 2 replies.
- [jira] [Created] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/06/15 19:59:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2120] Rename AbstractJobVertex to JobVe... - posted by mjsax <gi...@git.apache.org> on 2015/06/15 23:27:14 UTC, 3 replies.
- [jira] [Assigned] (FLINK-1870) Reintroduce Indexed reader functionality to streaming - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/15 23:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-1870) Reintroduce Indexed reader functionality to streaming - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/16 01:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/16 03:45:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/16 03:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2213) Configure number of vcores - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/16 04:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-2230) Add Support for Null-Values in TupleSerializer - posted by "Shiti Saxena (JIRA)" <ji...@apache.org> on 2015/06/16 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2231) Create a Serializer for Scala Enumerations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/16 09:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2213) Configure number of vcores - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/16 09:49:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/06/16 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2232) StormWordCountLocalITCase fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/16 10:13:00 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Some small fixups in README.md - posted by aljoscha <gi...@git.apache.org> on 2015/06/16 10:20:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-2230) Add Support for Null-Values in TupleSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/16 10:24:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-2232) StormWordCountLocalITCase fails - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/16 10:35:00 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2219) JobManagerInfoServlet IllegalArgumentException when pressing state button - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/16 10:36:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2229] add equals(...) and hashCode() to... - posted by sekruse <gi...@git.apache.org> on 2015/06/16 10:49:06 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2225) Erroneous scheduling of co-located tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/16 11:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2225) Erroneous scheduling of co-located tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/16 11:27:00 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2218) Web client cannot specify parallelism - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/16 12:02:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/16 13:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2232) StormWordCountLocalITCase fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/16 14:24:00 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2225] [scheduler] Excludes static code ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/16 14:41:23 UTC, 4 replies.
- [jira] [Created] (FLINK-2233) InputFormat nextRecord Javadocs out of sync - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/16 16:19:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2234) CoStreamWindow is Dependent on Input Ordering - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/16 16:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2232) StormWordCountLocalITCase fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/16 17:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2120) Rename AbstractJobVertex to JobVertex - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/16 17:18:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-2120) Rename AbstractJobVertex to JobVertex - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/16 17:21:02 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2226][YARN] fail application on failed ... - posted by asfgit <gi...@git.apache.org> on 2015/06/16 17:56:57 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2226) Fail YARN application on failed single-job YARN cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/16 17:58:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2214] [ml] Fixes prediction join operat... - posted by tillrohrmann <gi...@git.apache.org> on 2015/06/16 18:55:11 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2232] StormWordCountLocalITCase fails - posted by mjsax <gi...@git.apache.org> on 2015/06/16 23:37:07 UTC, 3 replies.
- [jira] [Closed] (FLINK-2210) Table API aggregate by ignoring null values - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/17 09:29:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne... - posted by chiwanpark <gi...@git.apache.org> on 2015/06/17 11:27:31 UTC, 4 replies.
- [jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/17 11:28:00 UTC, 4 replies.
- [GitHub] flink pull request: [Flink-1999] basic TfidfTransformer - posted by FGoessler <gi...@git.apache.org> on 2015/06/17 13:33:52 UTC, 44 replies.
- [GitHub] flink pull request: Csv read graph - posted by shghatge <gi...@git.apache.org> on 2015/06/17 14:02:37 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1520] Read edges and vertices from CSV ... - posted by andralungu <gi...@git.apache.org> on 2015/06/17 14:41:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/17 15:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/17 15:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/17 15:38:01 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f... - posted by shghatge <gi...@git.apache.org> on 2015/06/17 15:41:17 UTC, 49 replies.
- [GitHub] flink pull request: [FLINK-2124] [streaming] Fix behavior of FromE... - posted by jreiffers <gi...@git.apache.org> on 2015/06/17 15:56:50 UTC, 13 replies.
- [jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/17 15:57:01 UTC, 13 replies.
- [jira] [Assigned] (FLINK-2231) Create a Serializer for Scala Enumerations - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/06/17 16:25:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/06/17 16:26:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm - posted by "Johann Kovacs (JIRA)" <ji...@apache.org> on 2015/06/17 17:03:00 UTC, 5 replies.
- [jira] [Created] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/17 18:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2230) Add Support for Null-Values in TupleSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/17 18:30:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/17 18:31:01 UTC, 3 replies.
- [jira] [Updated] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/17 18:38:00 UTC, 1 replies.
- [jira] [Created] (FLINK-2237) Add hash-based Aggregation - posted by "Rafiullah Momand (JIRA)" <ji...@apache.org> on 2015/06/17 20:24:01 UTC, 0 replies.
- [GitHub] flink pull request: check in if clause in LongValue.java - posted by sahitya-pavurala <gi...@git.apache.org> on 2015/06/17 20:48:38 UTC, 10 replies.
- [jira] [Commented] (FLINK-2237) Add hash-based Aggregation - posted by "Shakirullah (JIRA)" <ji...@apache.org> on 2015/06/17 21:09:02 UTC, 3 replies.
- [GitHub] flink pull request: Modified the equals method in all the Value ty... - posted by sahitya-pavurala <gi...@git.apache.org> on 2015/06/17 23:17:36 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2180] [streaming] Iteration test fix - posted by gaborhermann <gi...@git.apache.org> on 2015/06/18 00:23:22 UTC, 2 replies.
- [jira] [Created] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/18 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2239) print() on DataSet: stream results and print incrementally - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/18 10:52:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2240) Use BloomFilter to minmize build side records which spilled to disk in Hybrid-Hash-Join - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/06/18 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2241) Use BloomFilter to minmize build side records which spilled to disk in Hybrid-Hash-Join - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/06/18 11:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2241) Use BloomFilter to minmize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/06/18 11:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2241) Use BloomFilter to minmize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/18 11:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/18 11:21:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/06/18 11:22:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2241) Use BloomFilter to minmize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/06/18 11:33:00 UTC, 0 replies.
- [GitHub] flink pull request: Version bumped to 0.10-SNAPSHOT - posted by mbalassi <gi...@git.apache.org> on 2015/06/18 12:43:45 UTC, 4 replies.
- [jira] [Created] (FLINK-2242) Deprecate RemoteCollector - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/18 17:09:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-2237) Add hash-based Aggregation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/18 20:46:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-2239) print() on DataSet: stream results and print incrementally - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/19 09:44:00 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2242] deprecate RemoteCollector interfa... - posted by mxm <gi...@git.apache.org> on 2015/06/19 10:43:03 UTC, 3 replies.
- [jira] [Commented] (FLINK-2242) Deprecate RemoteCollector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/19 10:44:00 UTC, 3 replies.
- [jira] [Created] (FLINK-2243) Add finite spout functionality to Storm compatibility layer - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/06/19 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2244) Add ability to start and stop persistent IaaS cluster - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 12:44:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 12:48:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2246) Combiner not chained - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/19 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2247) Improve the way memory is reported in the web frontend - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2248) Allow disabling of sdtout logging output - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 13:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2246) Add chained combine driver strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/19 13:40:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-2246) Add chained combine driver strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/19 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/19 14:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/19 14:22:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1404) Add support to cache intermediate results - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/19 14:22:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 14:27:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2250) Backtracking of intermediate results - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/19 14:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 14:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1404) Add support to cache intermediate results - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/19 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2251) Implement job session management - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/19 14:40:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1979] Lossfunctions - posted by thvasilo <gi...@git.apache.org> on 2015/06/19 14:44:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1979) Implement Loss Functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/19 14:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/19 14:47:00 UTC, 4 replies.
- [jira] [Created] (FLINK-2252) Reduce local input split assignment log level from INFO to DEBUG - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/19 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2253) ALS fails if the data flow is split up and the input is non-deterministic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/19 19:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2225) Erroneous scheduling of co-located tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/19 19:16:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2252) Reduce local input split assignment log level from INFO to DEBUG - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/19 20:55:02 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout... - posted by szape <gi...@git.apache.org> on 2015/06/20 13:05:49 UTC, 8 replies.
- [jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/20 13:06:00 UTC, 8 replies.
- [jira] [Resolved] (FLINK-2149) Simplify Gelly Jaccard similarity example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/20 16:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/21 00:33:00 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-1085: Unnecessary failing of GroupReduce... - posted by dabaitu <gi...@git.apache.org> on 2015/06/21 00:40:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/21 00:41:00 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-1085] Unnecessary failing of GroupReduc... - posted by rmetzger <gi...@git.apache.org> on 2015/06/21 00:51:56 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/21 01:02:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/21 01:29:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/06/21 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/21 09:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2140) Access the number of vertices from within the GSA functions - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/21 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/21 12:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2178) groupReduceOnNeighbors throws NoSuchElementException - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/21 13:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "Hubert Czerpak (JIRA)" <ji...@apache.org> on 2015/06/21 23:42:00 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana... - posted by uce <gi...@git.apache.org> on 2015/06/22 10:49:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 10:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/22 11:11:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa... - posted by uce <gi...@git.apache.org> on 2015/06/22 11:29:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-297) Redesign GUI client-server model - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 11:30:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/22 11:31:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2193) Partial shuffling - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 12:27:00 UTC, 0 replies.
- [GitHub] flink pull request: [streaming] Properly forward rich window funct... - posted by mbalassi <gi...@git.apache.org> on 2015/06/22 12:57:01 UTC, 4 replies.
- [jira] [Commented] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 12:58:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2190) Enhance stream decoration/compression extensibility - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 13:55:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse - posted by ggevay <gi...@git.apache.org> on 2015/06/22 14:00:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 14:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-2256) Handling Broker failures on the KafkaSink side - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/22 14:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 14:11:00 UTC, 1 replies.
- [jira] [Created] (FLINK-2257) Open and close of RichWindowFunctions is not called - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/22 14:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2257) Open and close of RichWindowFunctions is not called - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 14:18:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2255] [streaming] Fixed a bug in TopSpe... - posted by ggevay <gi...@git.apache.org> on 2015/06/22 15:00:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 15:01:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-1723) Add cross validation for model evaluation - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 15:01:00 UTC, 3 replies.
- [jira] [Created] (FLINK-2258) Add hyperparameter optimization to FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 15:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2157) Create evaluation framework for ML library - posted by "Mikio Braun (JIRA)" <ji...@apache.org> on 2015/06/22 15:25:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 15:25:01 UTC, 0 replies.
- [jira] [Created] (FLINK-2260) Have a complete model evaluation and selection framework for FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 16:16:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-2251) Implement job session management - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/22 16:24:03 UTC, 0 replies.
- [jira] [Updated] (FLINK-2097) Add support for JobSessions - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/22 16:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2251) Implement job session management - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/22 16:28:00 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2097] Implement job session management - posted by mxm <gi...@git.apache.org> on 2015/06/22 16:31:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-2097) Add support for JobSessions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 16:32:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2157) Create evaluation framework for ML library - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 16:41:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-2260) Have a complete model evaluation and selection framework for FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 16:41:03 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-1727]Decision tree - posted by thvasilo <gi...@git.apache.org> on 2015/06/22 16:46:56 UTC, 10 replies.
- [jira] [Reopened] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 17:10:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-2108) Add score function for Predictors - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/22 17:14:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-2244) Add ability to start and stop persistent IaaS cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 17:50:02 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo... - posted by mxm <gi...@git.apache.org> on 2015/06/22 17:51:50 UTC, 7 replies.
- [jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/22 17:58:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/22 18:10:00 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-1727][ml]Decision tree[WIP] - posted by sachingoel0101 <gi...@git.apache.org> on 2015/06/22 18:38:46 UTC, 3 replies.
- [jira] [Created] (FLINK-2261) Remove reduce/aggregation from DataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/22 20:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1541) GSoC project: Distributed profiling - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/22 20:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1319) Add static code analysis for UDFs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/22 21:01:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-536) Integrate Static Code Analysis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/22 21:01:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2261] [streaming] Remove reduce/fold/ag... - posted by gyfora <gi...@git.apache.org> on 2015/06/22 22:19:59 UTC, 10 replies.
- [jira] [Commented] (FLINK-2261) Remove reduce/aggregation from DataStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/22 22:20:01 UTC, 10 replies.
- [jira] [Created] (FLINK-2262) ParameterTool API misnamed function - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/06/22 22:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/23 10:26:00 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/06/23 10:47:51 UTC, 43 replies.
- [jira] [Reopened] (FLINK-2030) Implement an online histogram with Merging and equalization features - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/23 10:58:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/23 11:31:00 UTC, 2 replies.
- [jira] [Created] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/23 11:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2262) ParameterTool API misnamed function - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/23 12:26:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-2262) ParameterTool API misnamed function - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/23 15:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2262) ParameterTool API misnamed function - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/23 15:53:00 UTC, 0 replies.
- [GitHub] flink pull request: implement a simple session management - posted by mxm <gi...@git.apache.org> on 2015/06/23 16:03:48 UTC, 1 replies.
- [jira] [Created] (FLINK-2264) Migrate integration tests for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/23 16:49:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-2264) Migrate integration tests for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/23 16:52:00 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2125 - posted by hczerpak <gi...@git.apache.org> on 2015/06/24 00:23:56 UTC, 3 replies.
- [jira] [Created] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/24 09:49:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/24 09:49:43 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2174) Allow comments in 'slaves' file - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/24 10:05:42 UTC, 0 replies.
- [jira] [Created] (FLINK-2266) Building Flink for a specific HDP version fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/24 10:45:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2267) Support multi-class scoring for binary classification scores - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/24 11:43:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2268) Provide Flink binary release without Hadoop - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/24 11:45:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2269) Add Receiver operating characteristic (ROC) curve evaluation - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/24 11:48:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2248) Allow disabling of sdtout logging output - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/24 11:50:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2266) Building Flink for a specific HDP version fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/24 11:52:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-2266) Building Flink for a specific HDP version fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/24 11:52:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2264] [gelly] changed the tests to use ... - posted by samk3211 <gi...@git.apache.org> on 2015/06/24 12:43:50 UTC, 2 replies.
- [jira] [Commented] (FLINK-2264) Migrate integration tests for Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/24 12:44:04 UTC, 2 replies.
- [jira] [Created] (FLINK-2270) Error in KafkaSource Documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/24 12:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2271) PageRank gives wrong results with weighted graph input - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/24 13:36:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2271) PageRank gives wrong results with weighted graph input - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/24 13:38:04 UTC, 1 replies.
- [jira] [Created] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/24 13:59:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2272] [ml] [docs] Move vision and roadm... - posted by thvasilo <gi...@git.apache.org> on 2015/06/24 13:59:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/24 14:00:06 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/24 14:03:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2273) Register special Writable Kryo serializer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/24 15:14:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-1127) Utility library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/24 16:13:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2274) Add a histogram method for DataSet[Double] in DataSetUtils - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/24 17:00:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2274) Add a histogram method for DataSet[Double] in DataSetUtils - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/24 17:01:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2271) PageRank gives wrong results with weighted graph input - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/24 17:22:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2271] [FLINK-1522] [gelly] add missing ... - posted by vasia <gi...@git.apache.org> on 2015/06/24 23:52:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-2271) PageRank gives wrong results with weighted graph input - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/24 23:52:05 UTC, 2 replies.
- [jira] [Created] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators' - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/25 00:34:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2275] Migrate test from package 'org.ap... - posted by mjsax <gi...@git.apache.org> on 2015/06/25 03:07:48 UTC, 8 replies.
- [jira] [Commented] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/25 03:08:05 UTC, 8 replies.
- [jira] [Created] (FLINK-2276) Travis build error - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/25 12:10:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/25 13:41:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2230] handling null values for TupleSer... - posted by Shiti <gi...@git.apache.org> on 2015/06/25 13:46:19 UTC, 5 replies.
- [GitHub] flink pull request: [tools] Make release script a bit more flexibl... - posted by rmetzger <gi...@git.apache.org> on 2015/06/25 14:59:35 UTC, 6 replies.
- [jira] [Commented] (FLINK-2066) Make delay between execution retries configurable - posted by "Nuno Miguel Marques dos Santos (JIRA)" <ji...@apache.org> on 2015/06/25 18:55:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2232) StormWordCountLocalITCase fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/25 19:11:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2264) Migrate integration tests for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/25 23:32:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2093) Add a difference method to Gelly's Graph class - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/25 23:34:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1522) Add tests for the library methods and examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/25 23:36:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2271) PageRank gives wrong results with weighted graph input - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/06/25 23:40:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/26 10:07:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/26 10:08:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size - posted by "Christoph Alt (JIRA)" <ji...@apache.org> on 2015/06/26 12:03:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size - posted by "Christoph Alt (JIRA)" <ji...@apache.org> on 2015/06/26 12:06:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2116) Make pipeline extension require less coding - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/26 12:14:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2214) ALS predict and empiricalRisk function can cause hash join function to exceed maximum number of recursions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/26 12:15:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/26 12:16:04 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2278] [ml] changed Vector fromBreeze - posted by ChristophAl <gi...@git.apache.org> on 2015/06/26 12:20:14 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/26 12:34:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/26 12:34:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2279) Allow treating iteration head as ConnectedDataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 13:09:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2279] [streaming] Add Connected Iterati... - posted by gyfora <gi...@git.apache.org> on 2015/06/26 13:33:09 UTC, 6 replies.
- [jira] [Commented] (FLINK-2279) Allow treating iteration head as ConnectedDataStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/26 13:34:04 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram... - posted by thvasilo <gi...@git.apache.org> on 2015/06/26 14:08:59 UTC, 4 replies.
- [jira] [Commented] (FLINK-2157) Create evaluation framework for ML library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/26 14:09:05 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2138) PartitionCustom for streaming - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/06/26 14:13:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1736) Add CountVectorizer to machine learning library - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/26 15:08:04 UTC, 1 replies.
- [jira] [Created] (FLINK-2280) GenericTypeComparator.compare() does not respect ascending flag - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/26 16:34:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2138] Added custom partitioning to Data... - posted by gaborhermann <gi...@git.apache.org> on 2015/06/26 18:36:11 UTC, 13 replies.
- [jira] [Commented] (FLINK-2138) PartitionCustom for streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/26 18:37:04 UTC, 13 replies.
- [jira] [Closed] (FLINK-2129) User state checkpointing works only for serializable state - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:32:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1869) Make StreamDiscretizers chainable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:34:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1838) Update streaming programming guide - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:34:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2122) Make all internal streaming operators Checkpointable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:37:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2081) Change order of restore state and open for Streaming Operators - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:38:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-1972) Remove instanceID in streaming tasks - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:39:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2039) Streaming API's sum(String) does not work for Tuples - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:41:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:42:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-1853) TopSpeedWindowing example cannot be run from the ComandLine or Webclient - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:48:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:49:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2136) Test the streaming scala API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 20:51:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2281) Allow chaining of operators with multiple inputs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/26 22:32:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2122) Make all internal streaming operators Checkpointable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/26 22:57:04 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2122) Make all internal streaming operators Checkpointable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/27 18:41:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2279) Allow treating iteration head as ConnectedDataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/27 19:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1 - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/27 19:34:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/27 19:37:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/27 20:53:04 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2150] Added zipWithUniqueIds - posted by andralungu <gi...@git.apache.org> on 2015/06/28 16:47:13 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/06/28 19:35:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/06/28 19:35:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2066) Make delay between execution retries configurable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/29 09:47:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1735] Feature Hasher - posted by ChristophAl <gi...@git.apache.org> on 2015/06/29 10:14:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-1735) Add FeatureHasher to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/29 10:15:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2281) Allow chaining of operators with multiple inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/29 10:15:05 UTC, 1 replies.
- [jira] [Created] (FLINK-2284) Confusing/inconsistent PartitioningStrategy - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/29 10:40:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2285) Active policy emits elements of the last window twice - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/29 10:45:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2285) Active policy emits elements of the last window twice - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/29 10:45:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/29 10:49:04 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/06/29 10:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/29 10:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2287) Implement JobManager high availability - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/29 10:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2288) Setup ZooKeeper for distributed coordination - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/29 10:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2289) Make JobManager highly available - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/29 10:58:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2289) Make JobManager highly available - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/29 11:00:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-2284) Confusing/inconsistent PartitioningStrategy - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/29 11:05:04 UTC, 2 replies.
- [jira] [Closed] (FLINK-2281) Allow chaining of operators with multiple inputs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/29 11:08:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2282) Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1 - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/29 11:17:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2285] [streaming] Removed duplicate cal... - posted by mbalassi <gi...@git.apache.org> on 2015/06/29 11:23:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-2285) Active policy emits elements of the last window twice - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/29 11:24:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2290) CoRecordReader Does Not Read Events From Both Inputs When No Elements Arrive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/29 14:05:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2289) Make JobManager highly available - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/29 14:21:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2291) Use ZooKeeper to elect JobManager leader and send information to TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/29 14:24:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2291) Use ZooKeeper to elect JobManager leader and send information to TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/06/29 14:25:04 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2290) CoRecordReader Does Not Read Events From Both Inputs When No Elements Arrive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/29 14:29:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/29 14:37:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1960) Add comments and docs for withForwardedFields and related operators - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/29 15:44:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1573) Add per-job metrics to flink. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/30 10:08:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-766) Web interface progress monitoring for DataSources and DataSinks with splits - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/30 10:12:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2292) Report accumulators periodically while job is running - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/30 10:17:08 UTC, 0 replies.
- [jira] [Created] (FLINK-2293) Division by Zero Exception - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/30 10:27:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2293) Division by Zero Exception - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/30 10:33:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2293) Division by Zero Exception - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/30 10:36:04 UTC, 2 replies.
- [jira] [Updated] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/30 10:37:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2285) Active policy emits elements of the last window twice - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/06/30 10:37:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2290) CoRecordReader Does Not Read Events From Both Inputs When No Elements Arrive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/30 12:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2294) Keyed State does not work with DOP=1 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/30 12:33:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/30 12:39:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2294) Keyed State does not work with DOP=1 - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/30 12:42:04 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2294) Keyed State does not work with DOP=1 - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/30 13:40:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/30 13:56:04 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/30 13:56:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2294) Keyed State does not work with DOP=1 - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/30 14:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2296) Checkpoint committing broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 15:05:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2296) Checkpoint committing broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 15:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2297) Add threshold setting for SVM binary predictions - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/30 15:06:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2297] [ml] Add threshold setting for SV... - posted by thvasilo <gi...@git.apache.org> on 2015/06/30 15:07:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-2297) Add threshold setting for SVM binary predictions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/30 15:08:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-2296) Checkpoint committing broken - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/30 15:14:04 UTC, 5 replies.
- [jira] [Updated] (FLINK-2296) Checkpoint committing broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 15:17:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2298) Allow setting custom YARN application names through the CLI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 15:43:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/30 15:48:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 15:52:04 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/06/30 16:01:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2108) Add score function for Predictors - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/06/30 16:08:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2111) Add "stop" signal to cleanly stop streaming jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/30 16:21:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/06/30 16:21:05 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2296) Checkpoint committing broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 16:23:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/06/30 17:06:26 UTC, 3 replies.
- [jira] [Created] (FLINK-2300) Links on FAQ page not rendered correctly - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/06/30 17:29:04 UTC, 0 replies.
- [GitHub] flink pull request: [storm-contib] added named attribute access to... - posted by mjsax <gi...@git.apache.org> on 2015/06/30 17:54:13 UTC, 0 replies.
- [jira] [Created] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/06/30 18:06:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio... - posted by rmetzger <gi...@git.apache.org> on 2015/06/30 18:23:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/30 18:24:04 UTC, 2 replies.