flink-user mailing list archives: October 2016

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Tzu-Li (Gordon) Tai Re: Flink Checkpoint runs slow for low load stream Tue, 04 Oct, 08:25
Tzu-Li (Gordon) Tai Re: Presented Flink use case in Japan Tue, 04 Oct, 12:20
Tzu-Li (Gordon) Tai Re: ExpiredIteratorException when reading from a Kinesis stream Wed, 05 Oct, 03:55
Tzu-Li (Gordon) Tai Re: A question regarding to the checkpoint mechanism Mon, 17 Oct, 03:10
Tzu-Li (Gordon) Tai Re: A question regarding to the checkpoint mechanism Mon, 17 Oct, 05:57
Ufuk Celebi Re: Controlling savepoints from inside an application Tue, 04 Oct, 07:32
Ufuk Celebi Re: Exception while running Flink jobs (1.0.0) Wed, 05 Oct, 11:53
Ufuk Celebi Re: Exception while running Flink jobs (1.0.0) Thu, 06 Oct, 08:11
Ufuk Celebi Re: Exception while running Flink jobs (1.0.0) Thu, 06 Oct, 09:00
Ufuk Celebi Re: Exception while running Flink jobs (1.0.0) Thu, 06 Oct, 11:30
Ufuk Celebi Re: Exception while running Flink jobs (1.0.0) Wed, 12 Oct, 09:26
Ufuk Celebi Re: Keyed join Flink Streaming Thu, 13 Oct, 08:58
Ufuk Celebi Re: Clean up history of job manager Thu, 13 Oct, 09:02
Ufuk Celebi Re: Evolution algorithm on flink Thu, 13 Oct, 09:02
Ufuk Celebi [ANNOUNCE] Flink 1.1.3 Released Thu, 13 Oct, 15:23
Ufuk Celebi Re: Issue while restarting from SavePoint Wed, 19 Oct, 08:19
Ufuk Celebi Re: Reprocessing data in Flink / rebuilding Flink state Wed, 26 Oct, 14:07
Ufuk Celebi Re: Broadcast Config-Values through connected Configuration Stream Wed, 26 Oct, 14:09
Ufuk Celebi Re: Testing iterative data flows Thu, 27 Oct, 14:40
Vasiliki Kalavri Re: Flink error: Too few memory segments provided Thu, 20 Oct, 16:23
Vasiliki Kalavri Re: Flink error: Too few memory segments provided Fri, 21 Oct, 09:45
Vinay Patil Regarding Late Elements Mon, 03 Oct, 03:21
Wouter Ligtenberg question about making a temporal Graph with Gelly Wed, 12 Oct, 20:29
Yassine MARZOUGUI Handling decompression exceptions Tue, 04 Oct, 15:43
Yassine MARZOUGUI Re: Handling decompression exceptions Mon, 10 Oct, 08:57
Yassine MARZOUGUI Re: Handling decompression exceptions Tue, 11 Oct, 11:29
Yassine MARZOUGUI Re: Handling decompression exceptions Tue, 11 Oct, 11:37
Yassine MARZOUGUI Re: Handling decompression exceptions Tue, 11 Oct, 13:36
Yassine MARZOUGUI "java.net.SocketException: No buffer space available (maximum connections reached?)" when reading from HDFS Sat, 15 Oct, 20:11
Yassine MARZOUGUI Re: "java.net.SocketException: No buffer space available (maximum connections reached?)" when reading from HDFS Mon, 17 Oct, 07:31
Yassine MARZOUGUI BoundedOutOfOrdernessTimestampExtractor and allowedlateness Mon, 17 Oct, 09:52
Yassine MARZOUGUI Re: BoundedOutOfOrdernessTimestampExtractor and allowedlateness Mon, 17 Oct, 14:59
Yassine MARZOUGUI NoClassDefFoundError on cluster with httpclient 4.5.2 Wed, 19 Oct, 16:41
Yassine MARZOUGUI Re: NoClassDefFoundError on cluster with httpclient 4.5.2 Fri, 21 Oct, 10:34
Yassine MARZOUGUI Bug: Plan generation for Unions picked a ship strategy between binary plan operators. Tue, 25 Oct, 10:33
Yassine MARZOUGUI Re: Bug: Plan generation for Unions picked a ship strategy between binary plan operators. Tue, 25 Oct, 11:36
Yukun Guo ConcurrentModificationException when using histogram accumulators Fri, 14 Oct, 06:32
Zhangrucong About Sliding window Tue, 11 Oct, 11:20
Zhangrucong re: About Sliding window Tue, 11 Oct, 13:04
Zhangrucong re: About Sliding window Wed, 12 Oct, 13:36
Zhangrucong re: About Sliding window Thu, 13 Oct, 02:17
amir bahmanyari Re: Flink Metrics Mon, 17 Oct, 17:16
ankitcha Re: Flink Kafka Consumer Behaviour Tue, 04 Oct, 03:51
bart.kasterm...@kpn.com Testing a streaming data flow Mon, 17 Oct, 13:21
bart.kasterm...@kpn.com RE: Session windows - Evaluation of addition of element + window expires/gets discarded after some set time of inactivity Fri, 21 Oct, 14:31
drystan mazur Csv data stream Thu, 06 Oct, 20:08
drystan mazur DataStream csv reading Thu, 06 Oct, 20:21
drystan mazur Re: DataStream csv reading Thu, 06 Oct, 20:41
drystan mazur Re: DataStream csv reading Thu, 06 Oct, 20:43
drystan mazur Re: Csv data stream Thu, 06 Oct, 20:56
kant kodali Can we do batch writes on cassandra using flink while leveraging the locality? Thu, 27 Oct, 08:17
kant kodali Re: Can we do batch writes on cassandra using flink while leveraging the locality? Fri, 28 Oct, 06:57
lars.bachm...@posteo.de Compression for AvroOutputFormat Fri, 07 Oct, 10:40
lg...@yahoo.com Re: Regarding Late Elements Mon, 03 Oct, 15:05
lg...@yahoo.com Re: Regarding Late Elements Mon, 03 Oct, 15:28
lg...@yahoo.com Re: Listening to timed-out patterns in Flink CEP Fri, 07 Oct, 22:36
lg...@yahoo.com Re: more complex patterns for CEP (was: CEP two transitions to the same state) Fri, 07 Oct, 22:42
lg...@yahoo.com Re: Listening to timed-out patterns in Flink CEP Fri, 07 Oct, 22:50
lg...@yahoo.com Re: Listening to timed-out patterns in Flink CEP Sun, 09 Oct, 17:37
lg...@yahoo.com Re: more complex patterns for CEP (was: CEP two transitions to the same state) Tue, 11 Oct, 15:39
lg...@yahoo.com Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Tue, 11 Oct, 21:40
lg...@yahoo.com Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Tue, 11 Oct, 21:51
none none Flink job throws ClassNotFoundException on job restart Wed, 05 Oct, 09:50
otherwise777 Re: question about making a temporal Graph with Gelly Thu, 13 Oct, 09:44
otherwise777 Flink error: Too few memory segments provided Thu, 20 Oct, 15:24
otherwise777 Re: Flink error: Too few memory segments provided Fri, 21 Oct, 09:17
otherwise777 Re: Flink error: Too few memory segments provided Fri, 21 Oct, 10:09
otherwise777 Retrieving a single element from a DataSet Wed, 26 Oct, 12:41
otherwise777 Re: Retrieving a single element from a DataSet Wed, 26 Oct, 13:29
otherwise777 Looping over a DataSet and accesing another DataSet Sun, 30 Oct, 07:25
otherwise777 Re: Looping over a DataSet and accesing another DataSet Mon, 31 Oct, 09:54
otherwise777 Re: Looping over a DataSet and accesing another DataSet Mon, 31 Oct, 12:52
ram kumar Flink scala or Java - Dataload from CSV to database.. Tue, 04 Oct, 12:18
robert.lancas...@hyatt.com bucketing in RollingSink Wed, 12 Oct, 12:10
robert.lancas...@hyatt.com Re: bucketing in RollingSink Wed, 12 Oct, 16:33
robert.lancas...@hyatt.com Re: bucketing in RollingSink Thu, 13 Oct, 14:01
robert.lancas...@hyatt.com job failure with checkpointing enabled Fri, 14 Oct, 15:37
robert.lancas...@hyatt.com Re: job failure with checkpointing enabled Mon, 17 Oct, 12:39
robert.lancas...@hyatt.com native snappy library not available Wed, 19 Oct, 11:07
robert.lancas...@hyatt.com Re: native snappy library not available Wed, 19 Oct, 16:09
robert.lancas...@hyatt.com multiple processing of streams Wed, 19 Oct, 16:28
robert.lancas...@hyatt.com Re: native snappy library not available Thu, 20 Oct, 12:19
robert.lancas...@hyatt.com Re: multiple processing of streams Mon, 24 Oct, 11:59
robert.lancas...@hyatt.com Re: multiple processing of streams Mon, 24 Oct, 13:54
ruben.casado.teje...@accenture.com RE: [DISCUSS] Drop Hadoop 1 support with Flink 1.2 Thu, 13 Oct, 15:02
static-max Re: Flink job throws ClassNotFoundException on job restart Wed, 05 Oct, 13:48
static-max Re: Flink job throws ClassNotFoundException on job restart Wed, 05 Oct, 14:09
static-max "Slow ReadProcessor" warnings when using BucketSink Tue, 11 Oct, 08:51
static-max PathIsNotEmptyDirectoryException in Namenode HDFS log when using Jobmanager HA in YARN Tue, 11 Oct, 15:25
static-max Re: "Slow ReadProcessor" warnings when using BucketSink Tue, 18 Oct, 09:19
sunny patel AWS S3 and Reshift Wed, 05 Oct, 06:15
sunny patel Re: AWS S3 and Reshift Thu, 06 Oct, 09:14
sunny patel Re: jdbc.JDBCInputFormat Wed, 12 Oct, 09:49
sunny patel Re: jdbc.JDBCInputFormat Wed, 12 Oct, 10:39
sunny patel java.lang.IllegalArgumentException: JDBC-Class not found. - org.postgresql.jdbc.Driver Wed, 12 Oct, 21:18
swiesman Allowed Lateness and Window State Thu, 13 Oct, 14:16
swiesman Re: Allowed Lateness and Window State Thu, 13 Oct, 15:28
vinay patil Re: Regarding Late Elements Mon, 03 Oct, 15:09
vinay patil Re: Regarding Late Elements Tue, 04 Oct, 13:25
vinay patil Re: Regarding Late Elements Tue, 04 Oct, 15:42
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Jul 2019420
Jun 2019413
May 2019421
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