dev  

Messages by Date

• 2014/10/15 [jira] [Created] (FLINK-1167) CompilerException caused by NullPointerException Maximilian Alber (JIRA)
• 2014/10/15 Re: Cannot develop Scala API project in Eclipse Fabian Hueske
• 2014/10/15 Re: Cannot develop Scala API project in Eclipse Stephan Ewen
• 2014/10/15 Re: Cannot develop Scala API project in Eclipse Aljoscha Krettek
• 2014/10/15 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/15 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Kostas Tzoumas
• 2014/10/14 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Henry Saputra
• 2014/10/14 Cannot develop Scala API project in Eclipse Stephan Ewen
• 2014/10/14 [jira] [Created] (FLINK-1166) Add a QA bot to Flink that is testing pull requests Robert Metzger (JIRA)
• 2014/10/14 [jira] [Created] (FLINK-1165) No createCollectionsEnvironment in Java API Till Rohrmann (JIRA)
• 2014/10/13 Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Fabian Hueske
• 2014/10/13 [jira] [Created] (FLINK-1164) Uninformative error message when having an identity iteration with the Scala API Till Rohrmann (JIRA)
• 2014/10/13 [jira] [Created] (FLINK-1163) Scala DataSet cannot be used within iterations because it is not serializable Till Rohrmann (JIRA)
• 2014/10/13 [jira] [Created] (FLINK-1162) Cannot serialize Scala classes with Avro serializer Till Rohrmann (JIRA)
• 2014/10/13 [jira] [Created] (FLINK-1161) Modify streaming api type extractor classes to allow java 8 lambdas Gyula Fora (JIRA)
• 2014/10/13 [jira] [Created] (FLINK-1160) Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader Gyula Fora (JIRA)
• 2014/10/13 [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• 2014/10/13 [jira] [Created] (FLINK-1159) Case style anonymous functions not supported by Scala API Till Rohrmann (JIRA)
• 2014/10/13 [jira] [Created] (FLINK-1158) Logging property files missing in project created by archetypes Till Rohrmann (JIRA)
• 2014/10/13 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/13 Re: Please help testing the 0.7.0-incubating release candidate Fabian Hueske
• 2014/10/13 [jira] [Created] (FLINK-1157) Document TaskManager Slots Robert Metzger (JIRA)
• 2014/10/13 Re: 回复： a question about Exactly once processing Stephan Ewen
• 2014/10/13 [jira] [Created] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties) Aljoscha Krettek (JIRA)
• 2014/10/12 [jira] [Created] (FLINK-1155) Add Squirrel Logo to Flink website Robert Metzger (JIRA)
• 2014/10/12 回复： 回复： a question about Exactly once processing cY
• 2014/10/12 Re: 回复： a question about Exactly once processing Paris Carbone
• 2014/10/11 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/11 回复： a question about Exactly once processing cY
• 2014/10/11 Re: a question about Exactly once processing Gyula Fóra
• 2014/10/11 Re: a question about Exactly once processing cY
• 2014/10/11 a question about Exactly once processing cY
• 2014/10/11 [jira] [Created] (FLINK-1154) YarnTaskManagerRunner does not shut down Till Rohrmann (JIRA)
• 2014/10/11 [jira] [Created] (FLINK-1153) Yarn container does not terminate if Flink's yarn client is terminated before the application master is completely started Till Rohrmann (JIRA)
• 2014/10/11 Re: Please help testing the 0.7.0-incubating release candidate Stephan Ewen
• 2014/10/11 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/10 Re: Please help testing the 0.7.0-incubating release candidate Stephan Ewen
• 2014/10/10 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/10 Re: Flink streaming benchmark and comparison numbers? Kostas Tzoumas
• 2014/10/10 Re: Please help testing the 0.7.0-incubating release candidate Aljoscha Krettek
• 2014/10/10 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/10 Re: documentation 0.7 typo Robert Metzger
• 2014/10/10 documentation 0.7 typo graphael
• 2014/10/10 [jira] [Created] (FLINK-1152) Failed task cancellation leads to NullPointerException Robert Metzger (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1151) CollectionDataSource does not provide statistics Fabian Hueske (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1150) FilterNode set estimated data size to unknown Fabian Hueske (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1149) Operators cannot adapt DOP for NonParallelInputs Fabian Hueske (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1148) Create a writeAsCsv(path, writemode) variant Stephan Ewen (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1147) TypeInference on POJOs Stephan Ewen (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1146) Add a way to provide types for generic type variables Stephan Ewen (JIRA)
• 2014/10/09 [jira] [Created] (FLINK-1145) POJO Type extractor bug with type variables Stephan Ewen (JIRA)
• 2014/10/09 Re: Warnings about POJOs Aljoscha Krettek
• 2014/10/09 Warnings about POJOs Stephan Ewen
• 2014/10/09 Re: Marking affected and fixed versions in JIRA Fabian Hueske
• 2014/10/09 [jira] [Created] (FLINK-1144) Jobmanager Webfrontend task-totals are incorrect Robert Metzger (JIRA)
• 2014/10/08 [jira] [Created] (FLINK-1143) Forced to use Solution Set Maximilian Alber (JIRA)
• 2014/10/08 Marking affected and fixed versions in JIRA Ufuk Celebi
• 2014/10/08 [jira] [Created] (FLINK-1142) Log IOManager temp path directories Ufuk Celebi (JIRA)
• 2014/10/08 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/08 Re: Please help testing the 0.7.0-incubating release candidate Henry Saputra
• 2014/10/08 Re: Minor change to the versioning scheme Henry Saputra
• 2014/10/08 Re: Please help testing the 0.7.0-incubating release candidate Leonidas Fegaras
• 2014/10/08 Re: Minor change to the versioning scheme Till Rohrmann
• 2014/10/08 Re: Minor change to the versioning scheme Ufuk Celebi
• 2014/10/08 Re: [jira] [Commented] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size Stephan Ewen
• 2014/10/08 Re: Minor change to the versioning scheme Kostas Tzoumas
• 2014/10/08 Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/08 Re: Minor change to the versioning scheme Stephan Ewen
• 2014/10/08 Please help testing the 0.7.0-incubating release candidate Robert Metzger
• 2014/10/08 [jira] [Created] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size Robert Waury (JIRA)
• 2014/10/08 Re: Minor change to the versioning scheme Fabian Hueske
• 2014/10/08 Re: Minor change to the versioning scheme Robert Metzger
• 2014/10/08 Minor change to the versioning scheme Robert Metzger
• 2014/10/08 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/10/08 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/10/08 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/10/08 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/10/08 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/10/08 Re: Planning Flink release 0.7-incubating Till Rohrmann
• 2014/10/07 Re: Planning Flink release 0.7-incubating Márton Balassi
• 2014/10/07 Re: Flink streaming benchmark and comparison numbers? Henry Saputra
• 2014/10/07 Re: Flink streaming benchmark and comparison numbers? Márton Balassi
• 2014/10/07 Re: Planning Flink release 0.7-incubating Stephan Ewen
• 2014/10/07 [jira] [Created] (FLINK-1140) Add a flatmap that returns an Iterable instead of aggregation to a collector JIRA
• 2014/10/07 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/10/07 Re: Planning Flink release 0.7-incubating Stephan Ewen
• 2014/10/07 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/10/07 Flink streaming benchmark and comparison numbers? Henry Saputra
• 2014/10/07 Re: Planning Flink release 0.7-incubating Márton Balassi
• 2014/10/07 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/10/07 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/10/07 Re: Dependencies of streaming connectors Stephan Ewen
• 2014/10/07 Re: Planning Flink release 0.7-incubating Stephan Ewen
• 2014/10/07 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/10/07 Re: Dependencies of streaming connectors Márton Balassi
• 2014/10/06 [jira] [Created] (FLINK-1139) HadoopOutputFormat fails for DOP > 1 Fabian Hueske (JIRA)
• 2014/10/06 Re: load broadcast set into searchable set Stephan Ewen
• 2014/10/06 Re: load broadcast set into searchable set Martin Neumann
• 2014/10/06 Re: load broadcast set into searchable set Stephan Ewen
• 2014/10/06 load broadcast set into searchable set Martin Neumann
• 2014/10/05 Dependencies of streaming connectors Stephan Ewen
• 2014/10/05 [jira] [Created] (FLINK-1138) Allow users to specify methods instead of fields in key expressions Robert Metzger (JIRA)
• 2014/10/05 Re: Clean up dependencies in streaming connectors Márton Balassi
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Gyula Fóra
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Vasiliki Kalavri
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Paris Carbone
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Paris Carbone
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Vasiliki Kalavri
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Stephan Ewen
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Vasiliki Kalavri
• 2014/10/03 Re: Hackathon Stockholm - Agenda and Topics Aljoscha Krettek
• 2014/10/03 Hackathon Stockholm - Agenda and Topics Stephan Ewen
• 2014/10/03 [jira] [Created] (FLINK-1137) Add a way to configure mutable object safe mode versus object reuse Stephan Ewen (JIRA)
• 2014/10/02 [jira] [Created] (FLINK-1136) Put new Flink Logo in Web Frontends Fabian Hueske (JIRA)
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Fabian Hueske
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Stephan Ewen
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Stephan Ewen
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Stephan Ewen
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Fabian Hueske
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Márton Balassi
• 2014/10/01 [jira] [Created] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" Timo Walther (JIRA)
• 2014/10/01 [jira] [Created] (FLINK-1134) On the client side, the JVM does not terminate using RemoteCollectorOutputFormat Fabian Tschirschnitz (JIRA)
• 2014/10/01 [jira] [Created] (FLINK-1133) Type extractor cannot determine type of function Stephan Ewen (JIRA)
• 2014/10/01 Re: Apache Flink meetup in bay area by Robert and Ufuk Márton Balassi
• 2014/10/01 Re: Apache Flink meetup in bay area by Robert and Ufuk Ufuk Celebi
• 2014/10/01 Re: Eclipse issue after latest dependency rework pr Gyula Fora
• 2014/09/30 Re: Apache Flink meetup in bay area by Robert and Ufuk Robert Metzger
• 2014/09/30 Re: Eclipse issue after latest dependency rework pr Stephan Ewen
• 2014/09/30 Eclipse issue after latest dependency rework pr Gyula Fóra
• 2014/09/30 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/09/30 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/09/30 Re: Planning Flink release 0.7-incubating Stephan Ewen
• 2014/09/30 Re: Planning Flink release 0.7-incubating Gyula Fora
• 2014/09/30 Apache Flink meetup in bay area by Robert and Ufuk Henry Saputra
• 2014/09/30 Re: Keeping the reference to PACT compiler and Nephele names? Henry Saputra
• 2014/09/30 Re: Keeping the reference to PACT compiler and Nephele names? Kostas Tzoumas
• 2014/09/30 Re: Clean up dependencies in streaming connectors Stephan Ewen
• 2014/09/30 Re: Keeping the reference to PACT compiler and Nephele names? Ufuk Celebi
• 2014/09/29 Keeping the reference to PACT compiler and Nephele names? Henry Saputra
• 2014/09/29 Re: Clean up dependencies in streaming connectors Márton Balassi
• 2014/09/29 Re: Flink Hackathon in Stockholm (October 8th / 9th) Paris Carbone
• 2014/09/29 Re: Flink Hackathon in Stockholm (October 8th / 9th) Anirvan BASU
• 2014/09/29 Re: Shading Guava Dependency Stephan Ewen
• 2014/09/29 Re: Clean up dependencies in streaming connectors Stephan Ewen
• 2014/09/29 Re: Clean up dependencies in streaming connectors Gyula Fora
• 2014/09/29 Re: Clean up dependencies in streaming connectors Stephan Ewen
• 2014/09/29 Re: Clean up dependencies in streaming connectors Gyula Fóra
• 2014/09/29 Shading Guava Dependency Stephan Ewen
• 2014/09/29 Clean up dependencies in streaming connectors Stephan Ewen
• 2014/09/29 Re: [DISCUSS] Policy on keeping layer alternatives in sync Fabian Hueske
• 2014/09/29 Re: [DISCUSS] Policy on keeping layer alternatives in sync Aljoscha Krettek
• 2014/09/29 [jira] [Created] (FLINK-1132) Scala API has no partition operators Aljoscha Krettek (JIRA)
• 2014/09/29 [jira] [Created] (FLINK-1131) Scala API has no first(n) operation Aljoscha Krettek (JIRA)
• 2014/09/28 Re: Scala API rewrite almost complete Stephan Ewen
• 2014/09/28 Re: Scala API rewrite almost complete Aljoscha Krettek
• 2014/09/28 Re: Scala API rewrite almost complete Henry Saputra
• 2014/09/28 Re: Scala API rewrite almost complete Robert Metzger
• 2014/09/27 Re: [DISCUSS] Policy on keeping layer alternatives in sync Chesnay Schepler
• 2014/09/27 Re: Basic lambda prototype :) Paris Carbone
• 2014/09/27 Re: Basic lambda prototype :) Kostas Tzoumas
• 2014/09/27 Re: [DISCUSS] Policy on keeping layer alternatives in sync Kostas Tzoumas
• 2014/09/27 Re: Basic lambda prototype :) Stephan Ewen
• 2014/09/27 Re: Basic lambda prototype :) Ufuk Celebi
• 2014/09/26 Re: Basic lambda prototype :) Márton Balassi
• 2014/09/26 Basic lambda prototype :) Gyula Fóra
• 2014/09/26 Re: [DISCUSS] Policy on keeping layer alternatives in sync Robert Metzger
• 2014/09/26 Re: Question about Re-Partition Operator Aljoscha Krettek
• 2014/09/26 Re: [jira] [Created] (FLINK-1130) It is confusing what version a quickstart.sh is for. Ufuk Celebi
• 2014/09/26 [jira] [Created] (FLINK-1130) It is confusing what version a quickstart.sh is for. Aljoscha Krettek (JIRA)
• 2014/09/26 Re: [DISCUSS] Policy on keeping layer alternatives in sync Ufuk Celebi
• 2014/09/26 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/09/26 [DISCUSS] Policy on keeping layer alternatives in sync Fabian Hueske
• 2014/09/26 Re: Planning Flink release 0.7-incubating Aljoscha Krettek
• 2014/09/26 [jira] [Created] (FLINK-1129) The Plan Visualizer Cuts of the Lower Part of Certain Operators Aljoscha Krettek (JIRA)
• 2014/09/26 Re: Planning Flink release 0.7-incubating Stephan Ewen
• 2014/09/26 Re: Planning Flink release 0.7-incubating Daniel Warneke
• 2014/09/25 [jira] [Created] (FLINK-1128) We should also change Website to use Kramdown as Markdown Engine Aljoscha Krettek (JIRA)
• 2014/09/25 [jira] [Created] (FLINK-1127) Utility library Ufuk Celebi (JIRA)
• 2014/09/25 [jira] [Created] (FLINK-1126) Add suggestion for using large TupleX types Ufuk Celebi (JIRA)
• 2014/09/25 Re: Question about Re-Partition Operator Fabian Hueske
• 2014/09/25 [jira] [Created] (FLINK-1125) JobManager exception shown incompletely in TaskManager logs Ufuk Celebi (JIRA)
• 2014/09/25 [jira] [Created] (FLINK-1124) Merge error on TaskManager overview page Ufuk Celebi (JIRA)
• 2014/09/25 Re: Question about Re-Partition Operator Aljoscha Krettek
• 2014/09/25 Re: Streaming reduce discussion Fabian Hueske
• 2014/09/25 Re: Question about Re-Partition Operator Fabian Hueske
• 2014/09/25 Re: Streaming reduce discussion Gyula Fóra
• 2014/09/24 Re: Streaming reduce discussion Fabian Hueske
• 2014/09/24 Re: Planning Flink release 0.7-incubating Fabian Hueske
• 2014/09/24 Re: Planning Flink release 0.7-incubating Márton Balassi
• 2014/09/24 Re: Planning Flink release 0.7-incubating Ufuk Celebi
• 2014/09/24 Re: Planning Flink release 0.7-incubating Robert Metzger
• 2014/09/24 [jira] [Created] (FLINK-1123) Add First-N operator to Scala API Fabian Hueske (JIRA)
• 2014/09/24 [jira] [Created] (FLINK-1122) Add execute(String jobName) to StreamExecutionEnvironment JIRA
• 2014/09/24 Re: Website community/team page Márton Balassi
• 2014/09/24 Question about Re-Partition Operator Aljoscha Krettek
• 2014/09/24 [jira] [Created] (FLINK-1121) Add minBy and maxBy operators to the streaming api Gyula Fora (JIRA)
• 2014/09/24 [RESULT] [VOTE] Release Apache Flink 0.6.1-incubating Ufuk Celebi
• 2014/09/24 Streaming reduce discussion Gyula Fóra
• 2014/09/24 [jira] [Created] (FLINK-1120) Extend support for explict data set shuffling to Scala API Fabian Hueske (JIRA)
• 2014/09/23 [jira] [Created] (FLINK-1119) StreamComponentTest fails with NoResourceAvailableException Fabian Hueske (JIRA)

• Earlier messages
• Later messages