dev  

Messages by Date

• 2014/11/04 Re: Blog post for release 0.7.0 Flavio Pompermaier
• 2014/11/04 [jira] [Created] (FLINK-1209) Forgetting to close an iteration leads to a confusing error message Stephan Ewen (JIRA)
• 2014/11/04 Blog post for release 0.7.0 Kostas Tzoumas
• 2014/11/04 Regular Flink meetup in Berlin Kostas Tzoumas
• 2014/11/04 [jira] [Created] (FLINK-1208) Skip comment lines in CSV input format. Allow user to specify comment character. Aljoscha Krettek (JIRA)
• 2014/11/04 [FLINK-1040] Make type() call in projections optional Chen Xu
• 2014/11/04 Coarse-grained FT implementation Márton Balassi
• 2014/11/03 Re: Static context environment Ufuk Celebi
• 2014/11/03 Re: Static context environment Aljoscha Krettek
• 2014/11/03 [jira] [Created] (FLINK-1207) Switch ContextEnvironment to Environment factory Stephan Ewen (JIRA)
• 2014/11/03 Static context environment Stephan Ewen
• 2014/11/03 [jira] [Created] (FLINK-1206) Add option to the web client to specify default parallelism for a program Stephan Ewen (JIRA)
• 2014/11/03 [jira] [Created] (FLINK-1205) LibraryCacheManager should track execution IDs of library registrations Stephan Ewen (JIRA)
• 2014/11/03 [jira] [Created] (FLINK-1204) Fix streaming example builds to provide self-contained jars JIRA
• 2014/11/03 Incubator PMC/Board report for Nov 2014 ([ppmc]) Marvin
• 2014/11/03 [jira] [Created] (FLINK-1203) ClassCast exceptions in parallel tests (Surefire Bug?) Stephan Ewen (JIRA)
• 2014/11/03 Re: Issues with Java 8 Lambda Expressions Timo Walther
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
• 2014/11/03 [jira] [Created] (FLINK-1202) Failed file outputs should remove partially complete files Stephan Ewen (JIRA)
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/03 [jira] [Created] (FLINK-1201) Graph API for Flink Kostas Tzoumas (JIRA)
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/03 Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
• 2014/11/02 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Robert Metzger
• 2014/11/02 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/02 Re: Issues with Java 8 Lambda Expressions Stephan Ewen
• 2014/11/02 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/02 Re: Introduction Aljoscha Krettek
• 2014/11/02 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
• 2014/11/02 HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• 2014/11/01 Re: Introduction Stephan Ewen
• 2014/11/01 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Stephan Ewen
• 2014/11/01 Introduction Manu Kaul
• 2014/10/31 Re: load balancing groups Fabian Hueske
• 2014/10/31 Re: Hi / Aggregation support Fabian Hueske
• 2014/10/31 Re: load balancing groups Fabian Hueske
• 2014/10/31 Hi / Aggregation support Rosenfeld, Viktor
• 2014/10/31 [jira] [Created] (FLINK-1200) Add count() aggregate function to Java and Scala APIs Kostas Tzoumas (JIRA)
• 2014/10/30 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink sirinath
• 2014/10/30 Re: Type extraction with generic variables Vasiliki Kalavri
• 2014/10/30 Re: load balancing groups Fabian Hueske
• 2014/10/30 Re: Build error with Flink Suneel Marthi
• 2014/10/30 Re: Build error with Flink Stephan Ewen
• 2014/10/30 Re: Build error with Flink Stephan Ewen
• 2014/10/30 Re: Build error with Flink Suneel Marthi
• 2014/10/30 Re: Type extraction with generic variables Timo Walther
• 2014/10/30 Re: Build error with Flink Suneel Marthi
• 2014/10/30 Type extraction with generic variables Vasiliki Kalavri
• 2014/10/30 Re: Issues with Java 8 Lambda Expressions Stephan Ewen
• 2014/10/30 Re: Build error with Flink Stephan Ewen
• 2014/10/30 Build error with Flink Suneel Marthi
• 2014/10/29 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Henry Saputra
• 2014/10/29 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Ted Dunning
• 2014/10/29 [jira] [Created] (FLINK-1199) Correct references to dependencies in docs JIRA
• 2014/10/29 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Stephan Ewen
• 2014/10/29 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Márton Balassi
• 2014/10/29 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Robert Metzger
• 2014/10/29 Re: Issues with Java 8 Lambda Expressions Timo Walther
• 2014/10/28 [jira] [Created] (FLINK-1198) Store broadcast variables once per TaskManager Stephan Ewen (JIRA)
• 2014/10/28 Re: Contributing to the community. Fabian Hueske
• 2014/10/28 load balancing groups Martin Neumann
• 2014/10/28 Re: Case Study / Tutorial for Graph Analysis with Flink graphael
• 2014/10/28 Case Study / Tutorial for Graph Analysis with Flink Stephan Ewen
• 2014/10/28 [jira] [Created] (FLINK-1197) Special page on website that describes issues that occur together with types Timo Walther (JIRA)
• 2014/10/28 Contributing to the community. Saurabh Goyal
• 2014/10/28 Re: Issues with Java 8 Lambda Expressions Stephan Ewen
• 2014/10/28 Issues with Java 8 Lambda Expressions Timo Walther
• 2014/10/28 [jira] [Created] (FLINK-1196) Interfaces wrapping the persistence layer for source fault tolerance JIRA
• 2014/10/28 Re: [jira] [Created] (FLINK-1195) Improvement of benchmarking infrastructure Stephan Ewen
• 2014/10/28 [jira] [Created] (FLINK-1195) Improvement of benchmarking infrastructure Till Rohrmann (JIRA)
• 2014/10/28 Re: Code conventions in Scala Aljoscha Krettek
• 2014/10/27 Re: Code conventions in Scala Henry Saputra
• 2014/10/27 Re: Code conventions in Scala Till Rohrmann
• 2014/10/27 Code conventions in Scala Stephan Ewen
• 2014/10/27 Incubator PMC/Board report for Nov 2014 ([ppmc]) Marvin
• 2014/10/27 [jira] [Created] (FLINK-1194) Wrong manifest entries and compiler configuration in Java Quickstarts Stephan Ewen (JIRA)
• 2014/10/27 [jira] [Created] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]] Till Rohrmann (JIRA)
• 2014/10/27 [jira] [Created] (FLINK-1192) Streaming source fault tolerance JIRA
• 2014/10/27 [jira] [Created] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API Till Rohrmann (JIRA)
• 2014/10/27 [jira] [Created] (FLINK-1190) Enhanced windowing semantics JIRA
• 2014/10/27 [jira] [Created] (FLINK-1189) Temporal cross operator for streaming JIRA
• 2014/10/27 [jira] [Created] (FLINK-1188) Streaming aggregations on array types JIRA
• 2014/10/27 [jira] [Created] (FLINK-1187) API support for registering persistent states JIRA
• 2014/10/27 [jira] [Created] (FLINK-1185) State interfaces for streaming checkpointing JIRA
• 2014/10/27 [jira] [Created] (FLINK-1186) Join key selection for nested Tuples is broken Robert Waury (JIRA)
• 2014/10/27 [jira] [Created] (FLINK-1184) Streaming stateful computation support JIRA
• 2014/10/26 Re: [VOTE] Release Apache Flink 0.7.0-incubating Alan Cabrera
• 2014/10/26 Re: [VOTE] Release Apache Flink 0.7.0-incubating Stephan Ewen
• 2014/10/26 Re: [VOTE] Release Apache Flink 0.7.0-incubating Alan D. Cabrera
• 2014/10/26 Re: [VOTE] Release Apache Flink 0.7.0-incubating Alan D. Cabrera
• 2014/10/26 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Henry Saputra
• 2014/10/26 [jira] [Created] (FLINK-1183) Create warning when Flink is started with Java 6 Henry Saputra (JIRA)
• 2014/10/26 [jira] [Created] (FLINK-1182) Bad Error Message when trying to use expression keys on non-POJO types Stephan Ewen (JIRA)
• 2014/10/26 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Chiwan Park
• 2014/10/26 Re: [VOTE] Release Apache Flink 0.7.0-incubating Sean Owen
• 2014/10/26 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Aljoscha Krettek
• 2014/10/26 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Robert Metzger
• 2014/10/26 [RESULT] [VOTE] Release Apache Flink 0.7.0-incubating Robert Metzger
• 2014/10/24 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Henry Saputra
• 2014/10/24 [jira] [Created] (FLINK-1181) CLI actions list -r/-s don't work Vasia Kalavri (JIRA)
• 2014/10/23 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Stephan Ewen
• 2014/10/22 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Daniel Warneke
• 2014/10/22 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Aljoscha Krettek
• 2014/10/22 Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Mohit Singh
• 2014/10/22 [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Henry Saputra
• 2014/10/22 Re: Make Hadoop 2 the default profile Graphific
• 2014/10/22 RE: Make Hadoop 2 the default profile Kruse, Sebastian
• 2014/10/22 Re: Make Hadoop 2 the default profile Martin Neumann
• 2014/10/22 [VOTE] Release Apache Flink 0.7.0-incubating Robert Metzger
• 2014/10/21 [jira] [Created] (FLINK-1180) Expose Map and Reduce methods of hadoop via flink interface Mohitdeep Singh (JIRA)
• 2014/10/21 [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Robert Metzger
• 2014/10/21 Re: how load/group with large csv files Gyula Fóra
• 2014/10/21 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Ufuk Celebi
• 2014/10/21 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Robert Metzger
• 2014/10/21 Re: how load/group with large csv files Martin Neumann
• 2014/10/21 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Stephan Ewen
• 2014/10/21 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Henry Saputra
• 2014/10/21 Re: how load/group with large csv files Stephan Ewen
• 2014/10/21 Re: how load/group with large csv files Martin Neumann
• 2014/10/21 Re: how load/group with large csv files Stephan Ewen
• 2014/10/21 Re: how load/group with large csv files Aljoscha Krettek
• 2014/10/21 Re: how load/group with large csv files Martin Neumann
• 2014/10/21 Re: how load/group with large csv files Robert Metzger
• 2014/10/21 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Kostas Tzoumas
• 2014/10/21 Re: how load/group with large csv files Gyula Fora
• 2014/10/21 Re: how load/group with large csv files Martin Neumann
• 2014/10/21 Re: how load/group with large csv files Gyula Fora
• 2014/10/21 how load/group with large csv files Martin Neumann
• 2014/10/21 [jira] [Created] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager Robert Metzger (JIRA)
• 2014/10/21 Re: Make Hadoop 2 the default profile Till Rohrmann
• 2014/10/20 [jira] [Created] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType Till Rohrmann (JIRA)
• 2014/10/20 Re: Make Hadoop 2 the default profile Robert Metzger
• 2014/10/20 Re: Make Hadoop 2 the default profile Márton Balassi
• 2014/10/20 Make Hadoop 2 the default profile Stephan Ewen
• 2014/10/20 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Fabian Hueske
• 2014/10/20 [jira] [Created] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions Fabian Hueske (JIRA)
• 2014/10/19 [jira] [Created] (FLINK-1176) Add operator for global reduce/aggregations Gyula Fora (JIRA)
• 2014/10/19 [jira] [Created] (FLINK-1175) Add support for KeySelector and possibility to select more than one field for groupBy for streaming Gyula Fora (JIRA)
• 2014/10/19 [jira] [Created] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams Gyula Fora (JIRA)
• 2014/10/19 [jira] [Created] (FLINK-1173) Add socket text stream as a data source for the streaming API Gyula Fora (JIRA)
• 2014/10/19 Re: Help with starting contributing to Flink Gyula Fora
• 2014/10/19 [jira] [Created] (FLINK-1172) Links to APIs inside Iterations guide broken Robert Metzger (JIRA)
• 2014/10/19 Re: Help with starting contributing to Flink Robert Metzger
• 2014/10/18 Re: Help with starting contributing to Flink Ajay Bhat
• 2014/10/18 [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Robert Metzger
• 2014/10/18 Re: [GitHub] incubator-flink pull request: Bug fixes for iteration cornercases ... Stephan Ewen
• 2014/10/18 Re: Pull Requests for next Release Candidate Stephan Ewen
• 2014/10/18 Re: Pull Requests for next Release Candidate Robert Metzger
• 2014/10/18 Re: Help with starting contributing to Flink Robert Metzger
• 2014/10/18 Re: Help with starting contributing to Flink Robert Metzger
• 2014/10/17 Help with starting contributing to Flink Ajay Bhat
• 2014/10/17 Pull Requests for next Release Candidate Stephan Ewen
• 2014/10/17 Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/17 Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Márton Balassi
• 2014/10/17 Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/17 [jira] [Created] (FLINK-1171) Move scala tests to flink-tests project Stephan Ewen (JIRA)
• 2014/10/17 Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Robert Metzger
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Ufuk Celebi
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Kostas Tzoumas
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Stephan Ewen
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Fabian Hueske
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Robert Metzger
• 2014/10/17 Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Fabian Hueske
• 2014/10/17 [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Robert Metzger (JIRA)
• 2014/10/16 [VOTE] Apache Flink 0.7.0-incubating release Robert Metzger
• 2014/10/16 Re: Re: about hdfs in flink cluster Fabian Hueske
• 2014/10/16 Re: Re: about hdfs in flink cluster Robert Metzger
• 2014/10/16 [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/16 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/16 [jira] [Created] (FLINK-1169) Join Hint Specification in .join() Function is not Documented Aljoscha Krettek (JIRA)
• 2014/10/16 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Till Rohrmann
• 2014/10/16 Re:Re: about hdfs in flink cluster 杨洪波
• 2014/10/16 Re: about hdfs in flink cluster Kostas Tzoumas
• 2014/10/16 Re: about hdfs in flink cluster Stephan Ewen
• 2014/10/16 Re: CsvInputFormat delimiter fields Fabian Hueske
• 2014/10/16 [jira] [Created] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats Fabian Hueske (JIRA)
• 2014/10/16 Re: about hdfs in flink cluster Robert Metzger
• 2014/10/16 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Aljoscha Krettek
• 2014/10/16 Re: CsvInputFormat delimiter fields Fabian Hueske
• 2014/10/16 Re: about hdfs in flink cluster Márton Balassi
• 2014/10/15 about hdfs in flink cluster 杨洪波
• 2014/10/15 Re: Possible race condition in StreamRecordWriter Ufuk Celebi
• 2014/10/15 Re: Possible race condition in StreamRecordWriter Gyula Fóra
• 2014/10/15 Possible race condition in StreamRecordWriter Ufuk Celebi
• 2014/10/15 Re: How to group and sort the output of a join Aljoscha Krettek
• 2014/10/15 Re: CsvInputFormat delimiter fields Martin Neumann
• 2014/10/15 How to group and sort the output of a join Martin Neumann
• 2014/10/15 Re: CsvInputFormat delimiter fields Stephan Ewen
• 2014/10/15 CsvInputFormat delimiter fields Martin Neumann

• Earlier messages
• Later messages