flink-user mailing list archives: February 2015

Site index · List index
Message listThread · Author · Date
Vinh June CSV input with unknown # of fields and Custom output format Tue, 03 Feb, 21:31
Fabian Hueske   Re: CSV input with unknown # of fields and Custom output format Tue, 03 Feb, 23:07
Stephan Ewen     Re: CSV input with unknown # of fields and Custom output format Wed, 04 Feb, 08:43
Vinh June       Re: CSV input with unknown # of fields and Custom output format Wed, 04 Feb, 10:18
Stephan Ewen         Re: CSV input with unknown # of fields and Custom output format Wed, 04 Feb, 10:35
Vinh June           Re: CSV input with unknown # of fields and Custom output format Wed, 04 Feb, 10:52
Stephan Ewen             Re: CSV input with unknown # of fields and Custom output format Wed, 04 Feb, 11:50
Robert Waury Job fails with FileNotFoundException from blobStore Wed, 04 Feb, 13:48
Stephan Ewen   Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 07:55
Robert Waury     Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 08:27
Ufuk Celebi       Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 10:01
Robert Waury         Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 10:23
Ufuk Celebi           Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 12:14
Robert Waury             Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 14:21
Till Rohrmann               Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 14:29
Ufuk Celebi                 Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 15:10
Till Rohrmann                   Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 15:16
Stephan Ewen                     Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 15:23
Ufuk Celebi                       Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 15:40
Stephan Ewen                         Re: Job fails with FileNotFoundException from blobStore Thu, 05 Feb, 15:57
Kostas Tzoumas January 2015 in the Flink community Wed, 04 Feb, 13:52
Stefan Bunk Expressing `grep` with many search terms in Flink Wed, 04 Feb, 20:02
Fabian Hueske   Re: Expressing `grep` with many search terms in Flink Wed, 04 Feb, 20:34
Stephan Ewen     Re: Expressing `grep` with many search terms in Flink Thu, 05 Feb, 09:35
Vinh June Get 1 element of DataSet Thu, 05 Feb, 14:14
Stefan Bunk   Re: Get 1 element of DataSet Thu, 05 Feb, 14:27
Vinh June     Re: Get 1 element of DataSet Thu, 05 Feb, 14:34
Fabian Hueske       Re: Get 1 element of DataSet Thu, 05 Feb, 14:46
tanguy racinet flink loop Thu, 05 Feb, 19:37
Vasiliki Kalavri   Re: flink loop Thu, 05 Feb, 19:51
tanguy racinet     Re: flink loop Sun, 08 Feb, 11:38
Till Rohrmann       Re: flink loop Sun, 08 Feb, 12:07
tanguy racinet         Re: flink loop Sun, 08 Feb, 12:24
Till Rohrmann           Re: flink loop Sun, 08 Feb, 12:32
tanguy racinet             Re: flink loop Mon, 09 Feb, 15:46
Till Rohrmann               Re: flink loop Mon, 09 Feb, 16:09
Re: Not enough buffers when running Flink jar on cluster
rmetzger0   Re: Not enough buffers when running Flink jar on cluster Fri, 06 Feb, 16:08
Sebastian Flink cannot compile my join code... Tue, 10 Feb, 09:05
Aljoscha Krettek   Re: Flink cannot compile my join code... Tue, 10 Feb, 09:19
Sebastian     Re: Flink cannot compile my join code... Tue, 10 Feb, 09:51
Robert Metzger       Re: Flink cannot compile my join code... Tue, 10 Feb, 10:17
Sebastian         Re: Flink cannot compile my join code... Tue, 10 Feb, 11:09
Stephan Ewen           Re: Flink cannot compile my join code... Tue, 10 Feb, 11:12
Sebastian             Re: Flink cannot compile my join code... Tue, 10 Feb, 11:16
Kruse, Sebastian DeltaIterations: shrink solution set Tue, 10 Feb, 13:18
Alexander Alexandrov   Re: DeltaIterations: shrink solution set Tue, 10 Feb, 17:54
Vasiliki Kalavri     Re: DeltaIterations: shrink solution set Tue, 10 Feb, 18:14
Alexander Alexandrov       Re: DeltaIterations: shrink solution set Tue, 10 Feb, 20:43
Stephan Ewen         Re: DeltaIterations: shrink solution set Wed, 11 Feb, 09:01
Kruse, Sebastian           RE: DeltaIterations: shrink solution set Wed, 11 Feb, 09:40
Stephan Ewen             Re: DeltaIterations: shrink solution set Wed, 11 Feb, 09:43
Kruse, Sebastian               RE: DeltaIterations: shrink solution set Wed, 11 Feb, 10:12
Vinh June [Exception]Key expressions are only supported on POJO types and Tuples Wed, 11 Feb, 01:37
Vinh June   Re: [Exception]Key expressions are only supported on POJO types and Tuples Wed, 11 Feb, 01:42
Fabian Hueske     Re: [Exception]Key expressions are only supported on POJO types and Tuples Wed, 11 Feb, 08:59
Fabian Hueske       Re: [Exception]Key expressions are only supported on POJO types and Tuples Wed, 11 Feb, 09:08
Aljoscha Krettek         Re: [Exception]Key expressions are only supported on POJO types and Tuples Wed, 11 Feb, 10:09
HungChang Multiple sources shortest path Sat, 14 Feb, 11:26
Vasiliki Kalavri   Re: Multiple sources shortest path Sun, 15 Feb, 11:37
Sebastian     Re: Multiple sources shortest path Sun, 15 Feb, 16:32
Viktor Rosenfeld Does Flink use all of the available memory? Sat, 14 Feb, 12:58
Fabian Hueske   Re: Does Flink use all of the available memory? Sat, 14 Feb, 13:29
Viktor Rosenfeld     Re: Does Flink use all of the available memory? Sat, 14 Feb, 14:13
HungChang Can a master class control the superstep in Flink Spargel ? Sat, 14 Feb, 21:59
Vasiliki Kalavri   Re: Can a master class control the superstep in Flink Spargel ? Sun, 15 Feb, 12:21
Yiannis Gkoufas Exception in Simple Job: Thread 'SortMerger spilling thread' terminated due to an exception: The user-defined combiner failed in its 'open()' method Tue, 17 Feb, 17:00
Fabian Hueske   Re: Exception in Simple Job: Thread 'SortMerger spilling thread' terminated due to an exception: The user-defined combiner failed in its 'open()' method Tue, 17 Feb, 17:57
Fabian Hueske     Re: Exception in Simple Job: Thread 'SortMerger spilling thread' terminated due to an exception: The user-defined combiner failed in its 'open()' method Tue, 17 Feb, 18:01
Yiannis Gkoufas       Re: Exception in Simple Job: Thread 'SortMerger spilling thread' terminated due to an exception: The user-defined combiner failed in its 'open()' method Tue, 17 Feb, 18:08
HungChang Using Spargel's FilterOnVerices gets stuck. Wed, 18 Feb, 18:03
Vasiliki Kalavri   Re: Using Spargel's FilterOnVerices gets stuck. Wed, 18 Feb, 19:11
HungChang     Re: Using Spargel's FilterOnVerices gets stuck. Wed, 18 Feb, 19:53
Vasiliki Kalavri       Re: Using Spargel's FilterOnVerices gets stuck. Wed, 18 Feb, 21:16
HungChang         Re: Using Spargel's FilterOnVerices gets stuck. Wed, 18 Feb, 21:39
Carsten Brandt           Re: Using Spargel's FilterOnVerices gets stuck. Thu, 19 Feb, 19:06
Yiannis Gkoufas Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Wed, 18 Feb, 20:18
Stephan Ewen   Re: Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Wed, 18 Feb, 20:25
Fabian Hueske   Re: Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Wed, 18 Feb, 20:27
Yiannis Gkoufas     Re: Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Wed, 18 Feb, 21:59
Fabian Hueske       Re: Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Wed, 18 Feb, 22:13
Yiannis Gkoufas         Re: Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Thu, 19 Feb, 00:32
Henry Saputra           Re: Exception: Insufficient number of network buffers: required 120, but only 2 of 2048 available Thu, 19 Feb, 17:18
Kruse, Sebastian Efficient datatypes? Thu, 19 Feb, 09:23
Stephan Ewen   Re: Efficient datatypes? Thu, 19 Feb, 10:11
Plamen L. Simeonov     Re: Flink test examples Thu, 19 Feb, 11:24
Plamen L. Simeonov       Re: Flink test examples Thu, 19 Feb, 11:28
Robert Metzger         Re: Flink test examples Thu, 19 Feb, 21:21
Sebastian read .gz files Thu, 19 Feb, 20:25
Robert Metzger   Re: read .gz files Thu, 19 Feb, 20:31
Robert Metzger     Re: read .gz files Thu, 19 Feb, 20:36
Sebastian       Re: read .gz files Thu, 19 Feb, 20:56
Robert Metzger         Re: read .gz files Thu, 19 Feb, 21:08
Sebastian           Re: read .gz files Thu, 19 Feb, 22:23
OutOfMemory during serialization
Sebastian   OutOfMemory during serialization Fri, 20 Feb, 10:30
Fabian Hueske     Re: OutOfMemory during serialization Fri, 20 Feb, 10:41
Sebastian       Re: OutOfMemory during serialization Fri, 20 Feb, 10:48
Robert Metzger         Re: OutOfMemory during serialization Fri, 20 Feb, 11:11
Robert Metzger           Re: OutOfMemory during serialization Fri, 20 Feb, 11:44
Sebastian             Re: OutOfMemory during serialization Fri, 20 Feb, 12:03
Stephan Ewen               Re: OutOfMemory during serialization Fri, 20 Feb, 12:22
Ufuk Celebi                 Re: OutOfMemory during serialization Fri, 20 Feb, 13:02
Robert Metzger                   Re: OutOfMemory during serialization Fri, 20 Feb, 13:13
Robert Metzger                     Re: OutOfMemory during serialization Tue, 24 Feb, 18:39
Sebastian   OutOfMemory during serialization Fri, 20 Feb, 10:40
Yiannis Gkoufas Best strategy for calculating percentage Fri, 20 Feb, 21:01
Fabian Hueske   Re: Best strategy for calculating percentage Fri, 20 Feb, 22:18
Yiannis Gkoufas     Re: Best strategy for calculating percentage Sat, 21 Feb, 02:13
Vinh June Some questions about Join Sat, 21 Feb, 09:28
Fabian Hueske   Re: Some questions about Join Sat, 21 Feb, 10:40
Fabian Hueske     Re: Some questions about Join Sat, 21 Feb, 11:21
Yiannis Gkoufas MultipleFileOutput based on field Mon, 23 Feb, 15:43
Robert Metzger   Re: MultipleFileOutput based on field Mon, 23 Feb, 20:41
HungChang error in reduceGroup operator when changing the Flink version from 0.7 to 0.8 Tue, 24 Feb, 09:50
Stephan Ewen   Re: error in reduceGroup operator when changing the Flink version from 0.7 to 0.8 Tue, 24 Feb, 10:15
HungChang     Re: error in reduceGroup operator when changing the Flink version from 0.7 to 0.8 Tue, 24 Feb, 10:19
Aljoscha Krettek       Re: error in reduceGroup operator when changing the Flink version from 0.7 to 0.8 Tue, 24 Feb, 10:37
HungChang         Re: error in reduceGroup operator when changing the Flink version from 0.7 to 0.8 Tue, 24 Feb, 10:45
Giacomo Licari HDFS Clustering Tue, 24 Feb, 10:13
M├írton Balassi   Re: HDFS Clustering Tue, 24 Feb, 10:21
Max Michels   Re: HDFS Clustering Tue, 24 Feb, 10:31
Giacomo Licari     Re: HDFS Clustering Tue, 24 Feb, 10:44
Re: Subscribe request from a developer
Robert Metzger   Re: Subscribe request from a developer Tue, 24 Feb, 14:18
Leonidas Fegaras [ANNOUNCE] Apache MRQL 0.9.4-incubating released Thu, 26 Feb, 13:55
Message listThread · Author · Date
Box list
May 2019300
Apr 2019653
Mar 2019575
Feb 2019555
Jan 2019595
Dec 2018401
Nov 2018655
Oct 2018698
Sep 2018761
Aug 2018787
Jul 2018841
Jun 2018658
May 2018580
Apr 2018612
Mar 2018634
Feb 2018533
Jan 2018597
Dec 2017525
Nov 2017474
Oct 2017527
Sep 2017645
Aug 2017737
Jul 2017476
Jun 2017670
May 2017474
Apr 2017415
Mar 2017508
Feb 2017582
Jan 2017576
Dec 2016405
Nov 2016598
Oct 2016506
Sep 2016451
Aug 2016596
Jul 2016463
Jun 2016454
May 2016701
Apr 2016741
Mar 2016614
Feb 2016655
Jan 2016443
Dec 2015322
Nov 2015487
Oct 2015330
Sep 2015401
Aug 2015252
Jul 2015433
Jun 2015446
May 2015274
Apr 2015204
Mar 2015154
Feb 2015123
Jan 201574
Dec 201488
Nov 2014243
Oct 2014124
Sep 201464