Mailing list archives: October 2014

Site index · List index
Message list1 · 2 · 3 · Next »Thread · Author · Date
Đţ║Ú▓Ę about hdfs in flink cluster Thu, 16 Oct, 02:27
Đţ║Ú▓Ę Re:Re: about hdfs in flink cluster Thu, 16 Oct, 13:16
cY a question about Exactly once processing Sat, 11 Oct, 16:30
Gyula F├│ra Re: Hackathon Stockholm - Agenda and Topics Fri, 03 Oct, 18:22
Gyula F├│ra Re: a question about Exactly once processing Sat, 11 Oct, 16:38
Gyula F├│ra Re: Possible race condition in StreamRecordWriter Wed, 15 Oct, 15:23
Gyula F├│ra Re: how load/group with large csv files Tue, 21 Oct, 20:37
Márton Balassi Re: Apache Flink meetup in bay area by Robert and Ufuk Wed, 01 Oct, 11:24
Márton Balassi Re: Eclipse issue after latest dependency rework pr Wed, 01 Oct, 15:43
Márton Balassi Re: Clean up dependencies in streaming connectors Sun, 05 Oct, 12:15
Márton Balassi Re: Dependencies of streaming connectors Tue, 07 Oct, 11:45
Márton Balassi Re: Planning Flink release 0.7-incubating Tue, 07 Oct, 17:07
Márton Balassi Re: Flink streaming benchmark and comparison numbers? Tue, 07 Oct, 22:30
Márton Balassi Re: Planning Flink release 0.7-incubating Tue, 07 Oct, 23:51
Márton Balassi Re: about hdfs in flink cluster Thu, 16 Oct, 07:56
Márton Balassi Re: [RESULT] [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Fri, 17 Oct, 15:07
Márton Balassi Re: Make Hadoop 2 the default profile Mon, 20 Oct, 12:37
Márton Balassi Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Wed, 29 Oct, 16:58
cY Re: a question about Exactly once processing Sat, 11 Oct, 16:31
cY =?utf-8?B?5Zue5aSN77yaIGEgcXVlc3Rpb24gYWJvdXQgRXhh?= =?utf-8?B?Y3RseSBvbmNlIHByb2Nlc3Npbmc=?= Sat, 11 Oct, 16:43
cY =?utf-8?B?5Zue5aSN77yaIOWbnuWkje+8miBhIHF1ZXN0aW9u?= =?utf-8?B?IGFib3V0IEV4YWN0bHkgb25jZSBwcm9jZXNzaW5n?= Sun, 12 Oct, 12:26
Márton Balassi (JIRA) [jira] [Created] (FLINK-1140) Add a flatmap that returns an Iterable instead of aggregation to a collector Tue, 07 Oct, 21:34
Márton Balassi (JIRA) [jira] [Created] (FLINK-1184) Streaming stateful computation support Mon, 27 Oct, 09:57
Márton Balassi (JIRA) [jira] [Created] (FLINK-1185) State interfaces for streaming checkpointing Mon, 27 Oct, 10:01
Márton Balassi (JIRA) [jira] [Created] (FLINK-1187) API support for registering persistent states Mon, 27 Oct, 10:03
Márton Balassi (JIRA) [jira] [Created] (FLINK-1188) Streaming aggregations on array types Mon, 27 Oct, 10:56
Márton Balassi (JIRA) [jira] [Created] (FLINK-1189) Temporal cross operator for streaming Mon, 27 Oct, 10:59
Márton Balassi (JIRA) [jira] [Created] (FLINK-1190) Enhanced windowing semantics Mon, 27 Oct, 11:08
Márton Balassi (JIRA) [jira] [Created] (FLINK-1192) Streaming source fault tolerance Mon, 27 Oct, 11:15
Márton Balassi (JIRA) [jira] [Created] (FLINK-1196) Interfaces wrapping the persistence layer for source fault tolerance Tue, 28 Oct, 14:01
Márton Balassi (JIRA) [jira] [Created] (FLINK-1199) Correct references to dependencies in docs Wed, 29 Oct, 20:45
Ajay Bhat Help with starting contributing to Flink Sat, 18 Oct, 04:04
Ajay Bhat Re: Help with starting contributing to Flink Sun, 19 Oct, 03:03
Alan Cabrera Re: [VOTE] Release Apache Flink 0.7.0-incubating Mon, 27 Oct, 01:58
Alan D. Cabrera Re: [VOTE] Release Apache Flink 0.7.0-incubating Sun, 26 Oct, 22:30
Alan D. Cabrera Re: [VOTE] Release Apache Flink 0.7.0-incubating Sun, 26 Oct, 22:54
Aljoscha Krettek Re: Hackathon Stockholm - Agenda and Topics Fri, 03 Oct, 15:09
Aljoscha Krettek Re: Warnings about POJOs Thu, 09 Oct, 09:17
Aljoscha Krettek Re: Please help testing the 0.7.0-incubating release candidate Fri, 10 Oct, 16:53
Aljoscha Krettek Re: Cannot develop Scala API project in Eclipse Wed, 15 Oct, 12:50
Aljoscha Krettek Re: How to group and sort the output of a join Wed, 15 Oct, 14:08
Aljoscha Krettek Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Thu, 16 Oct, 09:44
Aljoscha Krettek Re: how load/group with large csv files Tue, 21 Oct, 13:07
Aljoscha Krettek Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Wed, 22 Oct, 19:35
Aljoscha Krettek Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Sun, 26 Oct, 08:53
Aljoscha Krettek Re: Code conventions in Scala Tue, 28 Oct, 07:07
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties) Mon, 13 Oct, 08:12
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-1169) Join Hint Specification in .join() Function is not Documented Thu, 16 Oct, 16:06
Chiwan Park Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Sun, 26 Oct, 10:24
Daniel Warneke Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Wed, 22 Oct, 20:38
Fabian Hueske Re: Eclipse issue after latest dependency rework pr Wed, 01 Oct, 16:03
Fabian Hueske Re: Eclipse issue after latest dependency rework pr Wed, 01 Oct, 20:14
Fabian Hueske Re: Planning Flink release 0.7-incubating Tue, 07 Oct, 15:20
Fabian Hueske Re: Planning Flink release 0.7-incubating Wed, 08 Oct, 08:50
Fabian Hueske Re: Planning Flink release 0.7-incubating Wed, 08 Oct, 10:19
Fabian Hueske Re: Planning Flink release 0.7-incubating Wed, 08 Oct, 10:29
Fabian Hueske Re: Minor change to the versioning scheme Wed, 08 Oct, 10:42
Fabian Hueske Re: Marking affected and fixed versions in JIRA Thu, 09 Oct, 07:46
Fabian Hueske Re: Please help testing the 0.7.0-incubating release candidate Mon, 13 Oct, 15:56
Fabian Hueske Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Mon, 13 Oct, 22:53
Fabian Hueske Re: Cannot develop Scala API project in Eclipse Wed, 15 Oct, 12:59
Fabian Hueske Re: CsvInputFormat delimiter fields Thu, 16 Oct, 09:28
Fabian Hueske Re: CsvInputFormat delimiter fields Thu, 16 Oct, 10:24
Fabian Hueske Re: Re: about hdfs in flink cluster Thu, 16 Oct, 19:40
Fabian Hueske Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Fri, 17 Oct, 09:58
Fabian Hueske Re: [jira] [Created] (FLINK-1170) Localization of InputSplits is not working properly Fri, 17 Oct, 10:11
Fabian Hueske Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Mon, 20 Oct, 11:27
Fabian Hueske Re: Contributing to the community. Tue, 28 Oct, 20:32
Fabian Hueske Re: load balancing groups Thu, 30 Oct, 16:56
Fabian Hueske Re: load balancing groups Fri, 31 Oct, 20:56
Fabian Hueske Re: Hi / Aggregation support Fri, 31 Oct, 21:17
Fabian Hueske Re: load balancing groups Fri, 31 Oct, 21:20
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1136) Put new Flink Logo in Web Frontends Thu, 02 Oct, 09:40
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1139) HadoopOutputFormat fails for DOP > 1 Mon, 06 Oct, 14:23
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1149) Operators cannot adapt DOP for NonParallelInputs Thu, 09 Oct, 13:31
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1150) FilterNode set estimated data size to unknown Thu, 09 Oct, 13:35
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1151) CollectionDataSource does not provide statistics Thu, 09 Oct, 13:37
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats Thu, 16 Oct, 10:23
Fabian Hueske (JIRA) [jira] [Created] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions Mon, 20 Oct, 07:43
Fabian Tschirschnitz (JIRA) [jira] [Created] (FLINK-1134) On the client side, the JVM does not terminate using RemoteCollectorOutputFormat Wed, 01 Oct, 14:45
Graphific Re: Make Hadoop 2 the default profile Wed, 22 Oct, 15:32
Gyula Fora Re: Eclipse issue after latest dependency rework pr Wed, 01 Oct, 07:40
Gyula Fora Re: Help with starting contributing to Flink Sun, 19 Oct, 10:53
Gyula Fora Re: how load/group with large csv files Tue, 21 Oct, 12:08
Gyula Fora Re: how load/group with large csv files Tue, 21 Oct, 12:20
Gyula Fora (JIRA) [jira] [Created] (FLINK-1160) Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader Mon, 13 Oct, 17:58
Gyula Fora (JIRA) [jira] [Created] (FLINK-1161) Modify streaming api type extractor classes to allow java 8 lambdas Mon, 13 Oct, 18:00
Gyula Fora (JIRA) [jira] [Created] (FLINK-1173) Add socket text stream as a data source for the streaming API Sun, 19 Oct, 16:22
Gyula Fora (JIRA) [jira] [Created] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams Sun, 19 Oct, 16:35
Gyula Fora (JIRA) [jira] [Created] (FLINK-1175) Add support for KeySelector and possibility to select more than one field for groupBy for streaming Sun, 19 Oct, 18:08
Gyula Fora (JIRA) [jira] [Created] (FLINK-1176) Add operator for global reduce/aggregations Sun, 19 Oct, 18:26
Henry Saputra Flink streaming benchmark and comparison numbers? Tue, 07 Oct, 17:15
Henry Saputra Re: Flink streaming benchmark and comparison numbers? Tue, 07 Oct, 22:45
Henry Saputra Re: Minor change to the versioning scheme Wed, 08 Oct, 18:46
Henry Saputra Re: Please help testing the 0.7.0-incubating release candidate Wed, 08 Oct, 18:46
Henry Saputra Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Tue, 14 Oct, 18:04
Henry Saputra Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC2) Tue, 21 Oct, 15:31
Henry Saputra [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Wed, 22 Oct, 17:53
Henry Saputra Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Fri, 24 Oct, 19:07
Henry Saputra Re: [DISCUSS] Bump the minimum Java requirement to Java 7 for Flink Sun, 26 Oct, 18:07
Box list
Jan 201741
Dec 2016366
Nov 2016429
Oct 2016552
Sep 2016426
Aug 2016586
Jul 2016455
Jun 2016386
May 2016405
Apr 2016535
Mar 2016421
Feb 2016502
Jan 2016389
Dec 2015259
Nov 2015589
Oct 2015589
Sep 2015449
Aug 2015478
Jul 2015503
Jun 2015880
May 2015491
Apr 2015583
Mar 2015716
Feb 2015545
Jan 2015600
Dec 2014303
Nov 2014375
Oct 2014283
Sep 2014430
Aug 2014314
Jul 2014390
Jun 2014990