You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Eclipse issue after latest dependency rework pr - posted by Gyula Fora <gy...@apache.org> on 2014/10/01 09:40:53 UTC, 6 replies.
- Re: Apache Flink meetup in bay area by Robert and Ufuk - posted by Ufuk Celebi <uc...@apache.org> on 2014/10/01 10:13:53 UTC, 1 replies.
- [jira] [Created] (FLINK-1133) Type extractor cannot determine type of function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/01 14:41:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1134) On the client side, the JVM does not terminate using RemoteCollectorOutputFormat - posted by "Fabian Tschirschnitz (JIRA)" <ji...@apache.org> on 2014/10/01 16:45:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/10/01 16:59:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1136) Put new Flink Logo in Web Frontends - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/02 11:40:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1137) Add a way to configure mutable object safe mode versus object reuse - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/03 13:35:33 UTC, 0 replies.
- Hackathon Stockholm - Agenda and Topics - posted by Stephan Ewen <se...@apache.org> on 2014/10/03 16:21:15 UTC, 8 replies.
- Re: Clean up dependencies in streaming connectors - posted by Márton Balassi <ba...@gmail.com> on 2014/10/05 14:15:31 UTC, 0 replies.
- [jira] [Created] (FLINK-1138) Allow users to specify methods instead of fields in key expressions - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/05 15:31:34 UTC, 0 replies.
- Dependencies of streaming connectors - posted by Stephan Ewen <se...@apache.org> on 2014/10/05 16:13:17 UTC, 2 replies.
- load broadcast set into searchable set - posted by Martin Neumann <mn...@spotify.com> on 2014/10/06 11:57:03 UTC, 3 replies.
- [jira] [Created] (FLINK-1139) HadoopOutputFormat fails for DOP > 1 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/06 16:23:34 UTC, 0 replies.
- Re: Planning Flink release 0.7-incubating - posted by Robert Metzger <rm...@apache.org> on 2014/10/07 13:53:36 UTC, 15 replies.
- Flink streaming benchmark and comparison numbers? - posted by Henry Saputra <he...@gmail.com> on 2014/10/07 19:15:12 UTC, 3 replies.
- [jira] [Created] (FLINK-1140) Add a flatmap that returns an Iterable instead of aggregation to a collector - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/07 23:34:33 UTC, 0 replies.
- Minor change to the versioning scheme - posted by Robert Metzger <rm...@apache.org> on 2014/10/08 12:38:40 UTC, 7 replies.
- [jira] [Created] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size - posted by "Robert Waury (JIRA)" <ji...@apache.org> on 2014/10/08 13:01:33 UTC, 0 replies.
- Please help testing the 0.7.0-incubating release candidate - posted by Robert Metzger <rm...@apache.org> on 2014/10/08 13:15:54 UTC, 13 replies.
- Re: [jira] [Commented] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size - posted by Stephan Ewen <se...@apache.org> on 2014/10/08 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1142) Log IOManager temp path directories - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/10/08 21:17:34 UTC, 0 replies.
- Marking affected and fixed versions in JIRA - posted by Ufuk Celebi <uc...@apache.org> on 2014/10/08 21:50:44 UTC, 1 replies.
- [jira] [Created] (FLINK-1143) Forced to use Solution Set - posted by "Maximilian Alber (JIRA)" <ji...@apache.org> on 2014/10/09 08:48:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1144) Jobmanager Webfrontend task-totals are incorrect - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/09 09:38:34 UTC, 0 replies.
- Warnings about POJOs - posted by Stephan Ewen <se...@apache.org> on 2014/10/09 11:03:14 UTC, 1 replies.
- [jira] [Created] (FLINK-1145) POJO Type extractor bug with type variables - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/09 11:24:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1146) Add a way to provide types for generic type variables - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/09 12:16:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1147) TypeInference on POJOs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/09 13:22:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1148) Create a writeAsCsv(path, writemode) variant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/09 13:38:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1149) Operators cannot adapt DOP for NonParallelInputs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/09 15:31:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1150) FilterNode set estimated data size to unknown - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/09 15:35:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1151) CollectionDataSource does not provide statistics - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/09 15:37:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1152) Failed task cancellation leads to NullPointerException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/10 10:17:34 UTC, 0 replies.
- documentation 0.7 typo - posted by graphael <gr...@gmail.com> on 2014/10/10 14:29:13 UTC, 1 replies.
- [jira] [Created] (FLINK-1153) Yarn container does not terminate if Flink's yarn client is terminated before the application master is completely started - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/11 17:44:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1154) YarnTaskManagerRunner does not shut down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/11 18:11:33 UTC, 0 replies.
- a question about Exactly once processing - posted by cY <32...@qq.com> on 2014/10/11 18:30:03 UTC, 2 replies.
- 回复： a question about Exactly once processing - posted by cY <32...@qq.com> on 2014/10/11 18:43:47 UTC, 2 replies.
- 回复： 回复： a question about Exactly once processing - posted by cY <32...@qq.com> on 2014/10/12 14:26:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1155) Add Squirrel Logo to Flink website - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/12 19:47:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/10/13 10:12:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1157) Document TaskManager Slots - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/13 14:23:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1158) Logging property files missing in project created by archetypes - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/13 18:38:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/13 18:43:34 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) - posted by Robert Metzger <rm...@apache.org> on 2014/10/13 18:59:23 UTC, 7 replies.
- [jira] [Created] (FLINK-1160) Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/13 19:58:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1161) Modify streaming api type extractor classes to allow java 8 lambdas - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/13 20:00:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1162) Cannot serialize Scala classes with Avro serializer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/13 23:49:36 UTC, 0 replies.
- [jira] [Created] (FLINK-1163) Scala DataSet cannot be used within iterations because it is not serializable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/14 00:18:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1164) Uninformative error message when having an identity iteration with the Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/14 00:31:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1165) No createCollectionsEnvironment in Java API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/14 10:51:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1166) Add a QA bot to Flink that is testing pull requests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/14 16:25:34 UTC, 0 replies.
- Cannot develop Scala API project in Eclipse - posted by Stephan Ewen <se...@apache.org> on 2014/10/14 19:09:47 UTC, 3 replies.
- CsvInputFormat delimiter fields - posted by Martin Neumann <mn...@spotify.com> on 2014/10/15 15:36:31 UTC, 4 replies.
- [jira] [Created] (FLINK-1167) CompilerException caused by NullPointerException - posted by "Maximilian Alber (JIRA)" <ji...@apache.org> on 2014/10/15 15:36:33 UTC, 0 replies.
- How to group and sort the output of a join - posted by Martin Neumann <mn...@spotify.com> on 2014/10/15 15:53:51 UTC, 1 replies.
- Possible race condition in StreamRecordWriter - posted by Ufuk Celebi <u....@fu-berlin.de> on 2014/10/15 17:18:09 UTC, 2 replies.
- about hdfs in flink cluster - posted by 杨洪波 <ho...@163.com> on 2014/10/16 04:27:12 UTC, 7 replies.
- [jira] [Created] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/16 12:23:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1169) Join Hint Specification in .join() Function is not Documented - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/10/16 18:06:33 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) - posted by Robert Metzger <rm...@apache.org> on 2014/10/16 21:06:28 UTC, 4 replies.
- [VOTE] Apache Flink 0.7.0-incubating release - posted by Robert Metzger <rm...@apache.org> on 2014/10/16 21:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/17 11:25:33 UTC, 7 replies.
- [jira] [Created] (FLINK-1171) Move scala tests to flink-tests project - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/17 16:46:34 UTC, 0 replies.
- Pull Requests for next Release Candidate - posted by Stephan Ewen <se...@apache.org> on 2014/10/18 00:36:12 UTC, 2 replies.
- Help with starting contributing to Flink - posted by Ajay Bhat <a....@gmail.com> on 2014/10/18 06:04:18 UTC, 5 replies.
- Re: [GitHub] incubator-flink pull request: Bug fixes for iteration cornercases ... - posted by Stephan Ewen <se...@apache.org> on 2014/10/18 20:50:53 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) - posted by Robert Metzger <rm...@apache.org> on 2014/10/18 22:38:34 UTC, 6 replies.
- [jira] [Created] (FLINK-1172) Links to APIs inside Iterations guide broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/19 10:47:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1173) Add socket text stream as a data source for the streaming API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/19 18:22:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/19 18:35:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1175) Add support for KeySelector and possibility to select more than one field for groupBy for streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/19 20:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1176) Add operator for global reduce/aggregations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/19 20:26:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/10/20 09:43:34 UTC, 0 replies.
- Make Hadoop 2 the default profile - posted by Stephan Ewen <se...@apache.org> on 2014/10/20 14:15:56 UTC, 6 replies.
- [jira] [Created] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/20 18:25:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/10/21 12:04:34 UTC, 0 replies.
- how load/group with large csv files - posted by Martin Neumann <mn...@spotify.com> on 2014/10/21 14:03:58 UTC, 11 replies.
- [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) - posted by Robert Metzger <rm...@apache.org> on 2014/10/21 23:25:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1180) Expose Map and Reduce methods of hadoop via flink interface - posted by "Mohitdeep Singh (JIRA)" <ji...@apache.org> on 2014/10/22 08:12:34 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.7.0-incubating - posted by Robert Metzger <rm...@apache.org> on 2014/10/22 09:29:21 UTC, 5 replies.
- [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink - posted by Henry Saputra <he...@gmail.com> on 2014/10/22 19:53:55 UTC, 10 replies.
- [jira] [Created] (FLINK-1181) CLI actions list -r/-s don't work - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2014/10/24 16:45:34 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 0.7.0-incubating - posted by Robert Metzger <rm...@apache.org> on 2014/10/26 08:45:43 UTC, 0 replies.
- [jira] [Created] (FLINK-1182) Bad Error Message when trying to use expression keys on non-POJO types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/26 17:25:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1183) Create warning when Flink is started with Java 6 - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2014/10/26 19:05:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1184) Streaming stateful computation support - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 10:57:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1186) Join key selection for nested Tuples is broken - posted by "Robert Waury (JIRA)" <ji...@apache.org> on 2014/10/27 11:01:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1185) State interfaces for streaming checkpointing - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 11:01:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1187) API support for registering persistent states - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 11:03:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1188) Streaming aggregations on array types - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 11:56:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1189) Temporal cross operator for streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 11:59:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1190) Enhanced windowing semantics - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 12:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/27 12:10:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1192) Streaming source fault tolerance - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/27 12:15:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]] - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/27 14:38:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1194) Wrong manifest entries and compiler configuration in Java Quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/27 14:54:33 UTC, 0 replies.
- Incubator PMC/Board report for Nov 2014 ([ppmc]) - posted by Marvin <no...@apache.org> on 2014/10/27 15:15:04 UTC, 5 replies.
- Code conventions in Scala - posted by Stephan Ewen <se...@apache.org> on 2014/10/27 21:04:23 UTC, 3 replies.
- [jira] [Created] (FLINK-1195) Improvement of benchmarking infrastructure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/10/28 09:41:33 UTC, 1 replies.
- Contributing to the community. - posted by Saurabh Goyal <sr...@gmail.com> on 2014/10/28 10:27:23 UTC, 1 replies.
- [jira] [Created] (FLINK-1196) Interfaces wrapping the persistence layer for source fault tolerance - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/28 15:01:34 UTC, 0 replies.
- Issues with Java 8 Lambda Expressions - posted by Timo Walther <fl...@twalthr.com> on 2014/10/28 15:27:34 UTC, 3 replies.
- [jira] [Created] (FLINK-1197) Special page on website that describes issues that occur together with types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/10/28 15:38:34 UTC, 0 replies.
- Case Study / Tutorial for Graph Analysis with Flink - posted by Stephan Ewen <se...@apache.org> on 2014/10/28 16:13:47 UTC, 1 replies.
- load balancing groups - posted by Martin Neumann <mn...@spotify.com> on 2014/10/28 20:53:48 UTC, 3 replies.
- [jira] [Created] (FLINK-1198) Store broadcast variables once per TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/10/28 21:59:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1199) Correct references to dependencies in docs - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/10/29 21:45:33 UTC, 0 replies.
- Build error with Flink - posted by Suneel Marthi <su...@gmail.com> on 2014/10/30 10:06:15 UTC, 6 replies.
- Type extraction with generic variables - posted by Vasiliki Kalavri <va...@gmail.com> on 2014/10/30 11:59:16 UTC, 2 replies.
- [jira] [Created] (FLINK-1200) Add count() aggregate function to Java and Scala APIs - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/10/31 11:31:33 UTC, 0 replies.
- Hi / Aggregation support - posted by "Rosenfeld, Viktor" <vi...@tu-berlin.de> on 2014/10/31 18:50:09 UTC, 1 replies.