dev@flink.apache.org, 2015-06

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

- Re: [DISCUSS] Streaming Sources (again) - posted by Stephan Ewen <se...@apache.org> on 2015/06/01 01:17:45 UTC, 0 replies.
- Re: [DISCUSS] Inconsistent naming of intermediate results - posted by Ufuk Celebi <uc...@apache.org> on 2015/06/01 10:01:31 UTC, 6 replies.
- MultipleLinearRegression - Strange results - posted by Felix Neutatz <ne...@googlemail.com> on 2015/06/01 11:48:11 UTC, 14 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.
- [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] [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.
- [DISCUSS] Consolidate method naming between the batch and streaming API - posted by Márton Balassi <ba...@gmail.com> on 2015/06/01 16:10:51 UTC, 6 replies.
- ResendUnfulfillableException at the end of failing job - posted by Márton Balassi <ba...@gmail.com> on 2015/06/01 16:52:01 UTC, 1 replies.
- Scala Tuple2 not recognized as a Scala Tuple - posted by Pieter-Jan Van Aeken <pi...@euranova.eu> on 2015/06/01 16:59:44 UTC, 2 replies.
- Old new web interface - posted by Matthias Schumacher <ma...@gmx.de> on 2015/06/01 19:10:22 UTC, 2 replies.
- Re: [ANNOUNCE] Apache Mahout 0.10.1 Released - posted by Dmitriy Lyubimov <dl...@gmail.com> on 2015/06/01 20:42:52 UTC, 0 replies.
- Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally - posted by Robert Metzger <rm...@apache.org> on 2015/06/01 21:36:54 UTC, 7 replies.
- Re: Storm compatibility layer currently does not support Storm's SimpleJoin example - posted by Robert Metzger <rm...@apache.org> on 2015/06/01 21:46:04 UTC, 2 replies.
- Re: Get the current TM hostname from the ExecutionContext - posted by Robert Metzger <rm...@apache.org> on 2015/06/01 21:47:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2128) ScalaShellITSuite failing - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/01 22:46: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.
- [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] [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.
- Re: Changed the behavior of "DataSet.print()" - posted by Robert Metzger <rm...@apache.org> on 2015/06/02 11:35:39 UTC, 9 replies.
- [FLINK-1731] [ML] Issues with vector to breeze converter while implementing KMeans - posted by Florian Gößler <ma...@floriangoessler.de> on 2015/06/02 13:10:58 UTC, 1 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] [Created] (FLINK-2134) Deadlock in SuccessAfterNetworkBuffersFailureITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/02 14:40:18 UTC, 0 replies.
- Re: [2/2] flink git commit: [ml] Replaces RichMapFunctions with mapWithBcVariable in FlinkML - posted by Sachin Goel <sa...@gmail.com> on 2015/06/02 17:33:00 UTC, 4 replies.
- Travis build failing - posted by Sachin Goel <sa...@gmail.com> on 2015/06/02 17:41:32 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:17 UTC, 0 replies.
- Writing test suites - posted by Sachin Goel <sa...@gmail.com> on 2015/06/02 17:50:23 UTC, 1 replies.
- Memory management overhaul - posted by Alexander Alexandrov <al...@gmail.com> on 2015/06/02 20:12:55 UTC, 1 replies.
- Re: "Validate" (commons) versus "checkArgument" (guava) - posted by Robert Metzger <rm...@apache.org> on 2015/06/02 21:11:43 UTC, 8 replies.
- Send events to parallel operator instances - posted by Gyula Fóra <gy...@apache.org> on 2015/06/02 22:45:02 UTC, 18 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.
- Buffer re-ordering problem - posted by "Kruse, Sebastian" <Se...@hpi.de> on 2015/06/03 09:54:43 UTC, 7 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] [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.
- Re: Gelly Blog Post - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/06/03 11:37:13 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: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.
- [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] [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.
- [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] [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] [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] [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.
- Re: [DISCUSS] State Management API for Streaming - posted by Stephan Ewen <se...@apache.org> on 2015/06/03 14:38:44 UTC, 0 replies.
- Re: Gelly Roadmap - posted by Stephan Ewen <se...@apache.org> on 2015/06/03 14:45:35 UTC, 5 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.
- Fwd: Discussion: Storm Comparability Layer - posted by Szabó Péter <ne...@gmail.com> on 2015/06/03 15:32:36 UTC, 5 replies.
- Null pointer exception on pl.project13.maven:git-commit-id-plugin:2.1.5:revision - posted by "F. Beligianni" <fa...@gmail.com> on 2015/06/03 15:46:38 UTC, 7 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:37 UTC, 0 replies.
- checkstyle failure - posted by Lokesh Rajaram <ra...@gmail.com> on 2015/06/03 16:27:34 UTC, 7 replies.
- GSoC work - posted by Sachin Goel <sa...@gmail.com> on 2015/06/03 16:41:32 UTC, 4 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.
- Re: Planning the 0.9 Release - posted by Robert Metzger <rm...@apache.org> on 2015/06/03 17:00:17 UTC, 22 replies.
- Build failure with maven-junction-plugin - posted by Theodore Vasiloudis <th...@gmail.com> on 2015/06/03 17:10:25 UTC, 2 replies.
- JIRA guidelines - posted by Lokesh Rajaram <ra...@gmail.com> on 2015/06/03 17:19:11 UTC, 3 replies.
- How do we want to maintain our documentation? - posted by Robert Metzger <rm...@apache.org> on 2015/06/03 17:21:55 UTC, 8 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.
- Failing tests policy - posted by Ufuk Celebi <uc...@apache.org> on 2015/06/04 00:32:26 UTC, 10 replies.
- Apache Flink transactions - posted by Hawin Jiang <ha...@gmail.com> on 2015/06/04 07:48:42 UTC, 2 replies.
- ALS implementation - posted by Felix Neutatz <ne...@googlemail.com> on 2015/06/04 09:59:31 UTC, 15 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] [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] [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] [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.
- [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:37 UTC, 0 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.
- Problem with ML pipeline - posted by Felix Neutatz <ne...@googlemail.com> on 2015/06/04 19:29:07 UTC, 13 replies.
- pull request for FLINK-2155 documentation - posted by Lokesh Rajaram <ra...@gmail.com> on 2015/06/05 07:46:26 UTC, 2 replies.
- Re: [GitHub] flink pull request: [FLINK-2000] [table] Add sql style aggregation... - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/05 10:05:23 UTC, 0 replies.
- [DISCUSS] TableAPI renaming toTable - posted by Fabian Hueske <fh...@gmail.com> on 2015/06/05 10:13:07 UTC, 5 replies.
- QA-Bot - posted by Robert Metzger <rm...@apache.org> on 2015/06/05 10:35:17 UTC, 4 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] [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] [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.
- Re: [jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by Fabian Hueske <fh...@gmail.com> on 2015/06/05 12:30:20 UTC, 0 replies.
- Local Python Test Execution Problem - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/05 12:33:23 UTC, 0 replies.
- Re: Local Python Test Execution Problem [Bug in Python Layer?] - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/05 13:59:03 UTC, 1 replies.
- Commment slaves - posted by Flavio Pompermaier <po...@okkam.it> on 2015/06/05 15:34:34 UTC, 3 replies.
- Closing JIRA issues - posted by Lokesh Rajaram <ra...@gmail.com> on 2015/06/05 17:24:51 UTC, 4 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] [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] [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:00 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] [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.
- Travis build issue - posted by Sachin Goel <sa...@gmail.com> on 2015/06/06 00:58:11 UTC, 1 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 mirror is down - posted by Márton Balassi <ba...@gmail.com> on 2015/06/06 22:06:00 UTC, 1 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.
- [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.
- Re: Memleak in the SessionWindowing example - posted by Robert Metzger <rm...@apache.org> on 2015/06/08 00:55:44 UTC, 1 replies.
- [jira] [Created] (FLINK-2181) SessionWindowing example has a memleak - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/06/08 09:43:04 UTC, 0 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.
- [jira] [Created] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/06/08 14:05:01 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.
- Testing Apache Flink 0.9.0-rc1 - posted by Maximilian Michels <mx...@apache.org> on 2015/06/08 18:52:41 UTC, 73 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:01 UTC, 0 replies.
- Code Style - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/09 09:02:42 UTC, 0 replies.
- Re: Code Style - posted by Aljoscha Krettek <al...@apache.org> on 2015/06/09 09:05:55 UTC, 1 replies.
- Checkstyle in IntelliJ - posted by Pieter-Jan Van Aeken <pi...@euranova.eu> on 2015/06/09 10:50:23 UTC, 9 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] [Created] (FLINK-2190) Enhance stream decoration/compression extensibility - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/06/09 14:49:00 UTC, 0 replies.
- Integration : Flink with OSGI - posted by santosh_rajaguru <sa...@gmail.com> on 2015/06/09 15:31:52 UTC, 1 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] [Created] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/06/09 20:02:00 UTC, 0 replies.
- Force enabling checkpoints for iterative streaming jobs - posted by Gyula Fóra <gy...@apache.org> on 2015/06/10 00:19:26 UTC, 21 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:01 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.
- The correct location for zipWithIndex and zipWithUniqueId - posted by Andra Lungu <an...@apache.org> on 2015/06/10 10:45:00 UTC, 6 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.
- Apache Flink 0.9 ALS API - posted by Ronny Bräunlich <r....@gmail.com> on 2015/06/10 11:28:45 UTC, 6 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.
- [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.
- [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.
- Adding flink-scala as a dependency to flink-streaming-core - posted by Gábor Gévay <gg...@gmail.com> on 2015/06/10 14:12:35 UTC, 9 replies.
- Build works locally but fails on travis (Storm compatibility) - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/10 14:22:38 UTC, 9 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] [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] [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.
- Run scala.App on Cluster - posted by Felix Neutatz <ne...@googlemail.com> on 2015/06/10 22:24:08 UTC, 3 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] [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] [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] [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.
- built problem - flink 0.9-SNAPSHOT - posted by Felix Neutatz <ne...@googlemail.com> on 2015/06/12 00:21:49 UTC, 4 replies.
- [jira] [Created] (FLINK-2208) Built error for IBM Java - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/06/12 01:00:06 UTC, 0 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.
- Listing Apache-2.0 dependencies in LICENSE file - posted by Till Rohrmann <tr...@apache.org> on 2015/06/12 18:33:49 UTC, 9 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.
- Testing Apache Flink 0.9.0-rc2 - posted by Maximilian Michels <mx...@apache.org> on 2015/06/14 18:11:45 UTC, 20 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.
- GSA based on edge direction - posted by Pieter-Jan Van Aeken <pi...@euranova.eu> on 2015/06/15 08:07:23 UTC, 1 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:00 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] [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] [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] [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] [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] [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.
- [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.
- Iteration stats logging - posted by Nam-Luc Tran <na...@euranova.eu> on 2015/06/15 15:53:07 UTC, 4 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] [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:01 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] [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] [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.
- The null in Flink - posted by Maximilian Michels <mx...@apache.org> on 2015/06/15 17:45:26 UTC, 3 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] [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.
- [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.
- ClassNotFound exception on a reduce group (Cluster mode) - posted by Thomas Peel <th...@euranova.eu> on 2015/06/16 09:17:48 UTC, 3 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.
- Shading artifact name - posted by Márton Balassi <ba...@gmail.com> on 2015/06/16 13:24:41 UTC, 4 replies.
- Question: SourceFunction - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/16 14:07:15 UTC, 3 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.
- [VOTE] Release Apache Flink 0.9.0 (release-0.9.0-rc3) - posted by Maximilian Michels <mx...@apache.org> on 2015/06/17 02:35:55 UTC, 6 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] [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] [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.
- Add hash based Aggregation - posted by ra...@mailbox.tu-berlin.de on 2015/06/17 22:41:13 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:00 UTC, 0 replies.
- [VOTE] [CANCELLED] Release Apache Flink 0.9.0 (release-0.9.0-rc3) - posted by Maximilian Michels <mx...@apache.org> on 2015/06/18 11:00:39 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:01 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.
- Use bloom filter to improve hybrid hash join performance - posted by "Li, Chengxiang" <ch...@intel.com> on 2015/06/18 11:37:19 UTC, 1 replies.
- [VOTE] Release Apache Flink 0.9.0 (release-0.9.0-rc4) - posted by Maximilian Michels <mx...@apache.org> on 2015/06/18 13:46:06 UTC, 5 replies.
- Quickstart POMs - posted by Ufuk Celebi <uc...@apache.org> on 2015/06/18 15:32:10 UTC, 11 replies.
- [jira] [Created] (FLINK-2242) Deprecate RemoteCollector - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/18 17:09:03 UTC, 0 replies.
- Re: Failing Builds on Travis - posted by Maximilian Michels <mx...@apache.org> on 2015/06/19 10:29:44 UTC, 6 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:00 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.
- Reduce combiner not chained - posted by Ufuk Celebi <uc...@apache.org> on 2015/06/19 13:04:17 UTC, 2 replies.
- Flink Runtime Exception - posted by Andra Lungu <lu...@gmail.com> on 2015/06/19 13:42:14 UTC, 10 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.
- execute() and collect()/print()/count() - posted by Maximilian Michels <mx...@apache.org> on 2015/06/19 14:15:19 UTC, 7 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] [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.
- [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, 2 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.
- Note #2 on the list - posted by Ted Dunning <te...@gmail.com> on 2015/06/20 00:59:48 UTC, 3 replies.
- Re: [jira] [Commented] (FLINK-2252) Reduce local input split assignment log level from INFO to DEBUG - posted by Fabian Hueske <fh...@gmail.com> on 2015/06/20 23:00:01 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] [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.
- Known minor streaming issue in 0.9.0 - posted by Márton Balassi <ba...@gmail.com> on 2015/06/22 13:04:56 UTC, 3 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.
- The household of the Kafka connector - posted by Márton Balassi <ba...@gmail.com> on 2015/06/22 14:08:30 UTC, 3 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] [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] [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:00 UTC, 0 replies.
- Removing reduce/aggregations from non-grouped data streams - posted by Gyula Fóra <gy...@apache.org> on 2015/06/22 17:32:21 UTC, 2 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.
- Thoughts About Streaming - posted by Aljoscha Krettek <al...@apache.org> on 2015/06/22 21:34:17 UTC, 30 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.
- Assertion Error in flink-test - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/23 10:04:51 UTC, 3 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.
- [RESULT] [VOTE] Release Apache Flink 0.9.0 (release-0.9.0-rc4) - posted by Maximilian Michels <mx...@apache.org> on 2015/06/23 13:57:45 UTC, 3 replies.
- Drafting the 0.9.0 release announcement - posted by Maximilian Michels <mx...@apache.org> on 2015/06/23 13:59:43 UTC, 15 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.
- Error while deserializing event - posted by Nam-Luc Tran <na...@euranova.eu> on 2015/06/23 17:27:51 UTC, 2 replies.
- New contributor - posted by Nuno Santos <n....@gmail.com> on 2015/06/23 19:22:36 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] [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.
- Running Flink Job with dependencies - posted by santosh_rajaguru <sa...@gmail.com> on 2015/06/24 11:28:28 UTC, 7 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.
- Provide Hadoop pre-build Hadoop 2.4 and Hadoop 2.6 binaries - posted by Robert Metzger <rm...@apache.org> on 2015/06/24 11:45:31 UTC, 8 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:05 UTC, 0 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] [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.
- [ANNOUNCE] Apache Flink 0.9.0 released - posted by Maximilian Michels <mx...@apache.org> on 2015/06/24 14:51:16 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] [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] [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.
- Possible bug? - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/25 03:03:14 UTC, 3 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.
- [VOTE] Release additional convenience binaries for Flink 0.9.0 - posted by Robert Metzger <rm...@apache.org> on 2015/06/25 14:28:24 UTC, 3 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] [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] [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.
- Stream iteration head as ConnectedDataStream - posted by Gyula Fóra <gy...@apache.org> on 2015/06/26 13:35:20 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.
- [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.
- Monitoring a Flink Job - posted by Andra Lungu <lu...@gmail.com> on 2015/06/27 16:19:35 UTC, 7 replies.
- Student looking to contribute to Stratosphere - posted by Rohit Shinde <ro...@gmail.com> on 2015/06/27 16:20:26 UTC, 1 replies.
- Possible Broken Master - posted by Aljoscha Krettek <al...@apache.org> on 2015/06/27 18:48:08 UTC, 3 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.
- Is there Any api that let DataStream join DataSet ? - posted by 马国维 <ma...@outlook.com> on 2015/06/28 04:29:40 UTC, 5 replies.
- [flink-ml] How to use ParameterMap in predict method? - posted by Chiwan Park <ch...@apache.org> on 2015/06/28 13:49:30 UTC, 4 replies.
- FLINK-2066 - posted by Nuno Santos <n....@gmail.com> on 2015/06/28 13:56:06 UTC, 5 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] [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.
- Off-by-one issues in the windowing code - posted by Márton Balassi <ba...@gmail.com> on 2015/06/29 11:02:12 UTC, 2 replies.
- Documentation not reachable - posted by Felix Neutatz <ne...@googlemail.com> on 2015/06/29 11:39:03 UTC, 3 replies.
- FYI: Flink documentation currently offline Fwd: [ NOTICE ] Services Unavailable - posted by Robert Metzger <rm...@apache.org> on 2015/06/29 12:28:01 UTC, 0 replies.
- [DISCUSS / VOTE] Signal name to "kill" streaming jobs - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/29 13:42:42 UTC, 6 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] [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:04 UTC, 0 replies.
- Replacing Checkpointed interface with field annotations - posted by Gyula Fóra <gy...@apache.org> on 2015/06/29 15:27:36 UTC, 1 replies.
- Storm Compatibility Improvement - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/06/29 18:02:14 UTC, 5 replies.
- [Runtime] Division by Zero Exception - posted by Andra Lungu <lu...@gmail.com> on 2015/06/29 23:24:36 UTC, 2 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] [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] [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] [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.
- [RESULT] [VOTE] Release additional convenience binaries for Flink 0.9.0 - posted by Robert Metzger <rm...@apache.org> on 2015/06/30 15:38:42 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] [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.
- [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.