dev  

Messages by Thread

• • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
• Introduction Manu Kaul
  • Re: Introduction Stephan Ewen
  • Re: Introduction Aljoscha Krettek
  • Introduction Kirschnick, Johannes
  • Re: Introduction Stephan Ewen
• Hi / Aggregation support Rosenfeld, Viktor
  • Re: Hi / Aggregation support Fabian Hueske
  • Re: Hi / Aggregation support viktor.rosenfeld
  • Re: Hi / Aggregation support Fabian Hueske
  • Re: Hi / Aggregation support Viktor Rosenfeld
  • Re: Hi / Aggregation support Aljoscha Krettek
  • Re: Hi / Aggregation support Gyula Fora
  • Re: Hi / Aggregation support Fabian Hueske
  • Re: Hi / Aggregation support Stephan Ewen
  • Re: Hi / Aggregation support Viktor Rosenfeld
  • Re: Hi / Aggregation support Viktor Rosenfeld
  • Re: Hi / Aggregation support Fabian Hueske
  • Re: Hi / Aggregation support Viktor Rosenfeld
  • Re: Hi / Aggregation support Aljoscha Krettek
  • Re: Hi / Aggregation support Fabian Hueske
  • Re: Hi / Aggregation support Aljoscha Krettek
  • Re: Hi / Aggregation support Fabian Hueske
• [jira] [Created] (FLINK-1200) Add count() aggregate function to Java and Scala APIs Kostas Tzoumas (JIRA)
• Type extraction with generic variables Vasiliki Kalavri
  • Re: Type extraction with generic variables Timo Walther
  • Re: Type extraction with generic variables Vasiliki Kalavri
  • Re: Type extraction with generic variables Vasiliki Kalavri
  • Re: Type extraction with generic variables Timo Walther
  • Re: Type extraction with generic variables Stephan Ewen
  • Re: Type extraction with generic variables Vasiliki Kalavri
• Build error with Flink Suneel Marthi
  • Re: Build error with Flink Stephan Ewen
  • Re: Build error with Flink Suneel Marthi
  • Re: Build error with Flink Suneel Marthi
  • Re: Build error with Flink Stephan Ewen
  • Re: Build error with Flink Stephan Ewen
  • Re: Build error with Flink Suneel Marthi
• [jira] [Created] (FLINK-1199) Correct references to dependencies in docs JIRA
• [jira] [Created] (FLINK-1198) Store broadcast variables once per TaskManager Stephan Ewen (JIRA)
• load balancing groups Martin Neumann
  • Re: load balancing groups Fabian Hueske
  • Re: load balancing groups Fabian Hueske
  • Re: load balancing groups Fabian Hueske
• Case Study / Tutorial for Graph Analysis with Flink Stephan Ewen
  • Re: Case Study / Tutorial for Graph Analysis with Flink graphael
• [jira] [Created] (FLINK-1197) Special page on website that describes issues that occur together with types Timo Walther (JIRA)
• Contributing to the community. Saurabh Goyal
  • Re: Contributing to the community. Fabian Hueske
• Issues with Java 8 Lambda Expressions Timo Walther
  • Re: Issues with Java 8 Lambda Expressions Stephan Ewen
  • Re: Issues with Java 8 Lambda Expressions Timo Walther
  • Re: Issues with Java 8 Lambda Expressions Stephan Ewen
  • Re: Issues with Java 8 Lambda Expressions Stephan Ewen
  • Re: Issues with Java 8 Lambda Expressions Timo Walther
  • Re: Issues with Java 8 Lambda Expressions Stephan Ewen
  • Re: Issues with Java 8 Lambda Expressions Timo Walther
  • Re: Issues with Java 8 Lambda Expressions Ufuk Celebi
  • Re: Issues with Java 8 Lambda Expressions Stephan Ewen
• [jira] [Created] (FLINK-1196) Interfaces wrapping the persistence layer for source fault tolerance JIRA
• [jira] [Created] (FLINK-1195) Improvement of benchmarking infrastructure Till Rohrmann (JIRA)
  • Re: [jira] [Created] (FLINK-1195) Improvement of benchmarking infrastructure Stephan Ewen
• Code conventions in Scala Stephan Ewen
  • Re: Code conventions in Scala Till Rohrmann
  • Re: Code conventions in Scala Henry Saputra
  • Re: Code conventions in Scala Aljoscha Krettek
• Incubator PMC/Board report for Nov 2014 ([ppmc]) Marvin
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Robert Metzger
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Márton Balassi
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Stephan Ewen
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Ted Dunning
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Henry Saputra
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Robert Metzger
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Ted Dunning
  • Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Henry Saputra
  • Incubator PMC/Board report for Nov 2014 ([ppmc]) Marvin
• [jira] [Created] (FLINK-1194) Wrong manifest entries and compiler configuration in Java Quickstarts Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]] Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1192) Streaming source fault tolerance JIRA
• [jira] [Created] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1190) Enhanced windowing semantics JIRA
• [jira] [Created] (FLINK-1189) Temporal cross operator for streaming JIRA
• [jira] [Created] (FLINK-1188) Streaming aggregations on array types JIRA
• [jira] [Created] (FLINK-1187) API support for registering persistent states JIRA
• [jira] [Created] (FLINK-1185) State interfaces for streaming checkpointing JIRA
• [jira] [Created] (FLINK-1186) Join key selection for nested Tuples is broken Robert Waury (JIRA)
• [jira] [Created] (FLINK-1184) Streaming stateful computation support JIRA
• [jira] [Created] (FLINK-1183) Create warning when Flink is started with Java 6 Henry Saputra (JIRA)
• [jira] [Created] (FLINK-1182) Bad Error Message when trying to use expression keys on non-POJO types Stephan Ewen (JIRA)
• [RESULT] [VOTE] Release Apache Flink 0.7.0-incubating Robert Metzger
• [jira] [Created] (FLINK-1181) CLI actions list -r/-s don't work Vasia Kalavri (JIRA)
• [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Henry Saputra
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Mohit Singh
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Aljoscha Krettek
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Daniel Warneke
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Stephan Ewen
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Henry Saputra
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Robert Metzger
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Aljoscha Krettek
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Chiwan Park
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Henry Saputra
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink sirinath
  • Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Stephan Ewen
• [VOTE] Release Apache Flink 0.7.0-incubating Robert Metzger
  • Re: [VOTE] Release Apache Flink 0.7.0-incubating Sean Owen
  • Re: [VOTE] Release Apache Flink 0.7.0-incubating Alan D. Cabrera
  • Re: [VOTE] Release Apache Flink 0.7.0-incubating Alan D. Cabrera
  • Re: [VOTE] Release Apache Flink 0.7.0-incubating Stephan Ewen
  • Re: [VOTE] Release Apache Flink 0.7.0-incubating Alan Cabrera
• [jira] [Created] (FLINK-1180) Expose Map and Reduce methods of hadoop via flink interface Mohitdeep Singh (JIRA)
• how load/group with large csv files Martin Neumann
  • Re: how load/group with large csv files Gyula Fora
  • Re: how load/group with large csv files Martin Neumann
  • Re: how load/group with large csv files Gyula Fora
  • Re: how load/group with large csv files Robert Metzger
  • Re: how load/group with large csv files Martin Neumann
  • Re: how load/group with large csv files Aljoscha Krettek
  • Re: how load/group with large csv files Stephan Ewen
  • Re: how load/group with large csv files Martin Neumann
  • Re: how load/group with large csv files Stephan Ewen
  • Re: how load/group with large csv files Martin Neumann
  • Re: how load/group with large csv files Gyula Fóra
• [jira] [Created] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType Till Rohrmann (JIRA)
• Make Hadoop 2 the default profile Stephan Ewen
  • Re: Make Hadoop 2 the default profile Márton Balassi
  • Re: Make Hadoop 2 the default profile Robert Metzger
  • Re: Make Hadoop 2 the default profile Till Rohrmann
  • Re: Make Hadoop 2 the default profile Martin Neumann
  • RE: Make Hadoop 2 the default profile Kruse, Sebastian
  • Re: Make Hadoop 2 the default profile Graphific
• [jira] [Created] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1176) Add operator for global reduce/aggregations Gyula Fora (JIRA)
• [jira] [Created] (FLINK-1175) Add support for KeySelector and possibility to select more than one field for groupBy for streaming Gyula Fora (JIRA)
• [jira] [Created] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams Gyula Fora (JIRA)
• [jira] [Created] (FLINK-1173) Add socket text stream as a data source for the streaming API Gyula Fora (JIRA)
• [jira] [Created] (FLINK-1172) Links to APIs inside Iterations guide broken Robert Metzger (JIRA)
• [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Robert Metzger
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Fabian Hueske
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Kostas Tzoumas
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Henry Saputra
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Stephan Ewen
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Robert Metzger
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Ufuk Celebi
  • [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Robert Metzger
• Re: [GitHub] incubator-flink pull request: Bug fixes for iteration cornercases ... Stephan Ewen
• Help with starting contributing to Flink Ajay Bhat
  • Re: Help with starting contributing to Flink Robert Metzger
  • Re: Help with starting contributing to Flink Robert Metzger
  • Re: Help with starting contributing to Flink Ajay Bhat
  • Re: Help with starting contributing to Flink Robert Metzger
  • Re: Help with starting contributing to Flink Gyula Fora
• Pull Requests for next Release Candidate Stephan Ewen
  • Re: Pull Requests for next Release Candidate Robert Metzger
  • Re: Pull Requests for next Release Candidate Stephan Ewen
• [jira] [Created] (FLINK-1171) Move scala tests to flink-tests project Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Robert Metzger (JIRA)
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Fabian Hueske
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Robert Metzger
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Fabian Hueske
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Stephan Ewen
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Kostas Tzoumas
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Ufuk Celebi
  • Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Robert Metzger
• [VOTE] Apache Flink 0.7.0-incubating release Robert Metzger
• [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
  • Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
  • Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
  • Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Márton Balassi
  • Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• [jira] [Created] (FLINK-1169) Join Hint Specification in .join() Function is not Documented Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats Fabian Hueske (JIRA)
• about hdfs in flink cluster 杨洪波
  • Re: about hdfs in flink cluster Márton Balassi
  • Re: about hdfs in flink cluster Robert Metzger
  • Re: about hdfs in flink cluster Kostas Tzoumas
  • Re:Re: about hdfs in flink cluster 杨洪波
  • Re: Re: about hdfs in flink cluster Robert Metzger
  • Re: Re: about hdfs in flink cluster Fabian Hueske
  • Re: about hdfs in flink cluster Stephan Ewen
• Possible race condition in StreamRecordWriter Ufuk Celebi
  • Re: Possible race condition in StreamRecordWriter Gyula Fóra
  • Re: Possible race condition in StreamRecordWriter Ufuk Celebi
• How to group and sort the output of a join Martin Neumann
  • Re: How to group and sort the output of a join Aljoscha Krettek
• CsvInputFormat delimiter fields Martin Neumann
  • Re: CsvInputFormat delimiter fields Stephan Ewen
  • Re: CsvInputFormat delimiter fields Martin Neumann
  • Re: CsvInputFormat delimiter fields Fabian Hueske
  • Re: CsvInputFormat delimiter fields Fabian Hueske
• [jira] [Created] (FLINK-1167) CompilerException caused by NullPointerException Maximilian Alber (JIRA)
• Cannot develop Scala API project in Eclipse Stephan Ewen
  • Re: Cannot develop Scala API project in Eclipse Aljoscha Krettek
  • Re: Cannot develop Scala API project in Eclipse Stephan Ewen
  • Re: Cannot develop Scala API project in Eclipse Fabian Hueske
• [jira] [Created] (FLINK-1166) Add a QA bot to Flink that is testing pull requests Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1165) No createCollectionsEnvironment in Java API Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1164) Uninformative error message when having an identity iteration with the Scala API Till Rohrmann (JIRA)

• Earlier messages
• Later messages