flink-user mailing list archives: October 2017

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Kostas Kloudas Re: Issue with CEP library Sun, 01 Oct, 06:18
Timo Walther Re: Windowing isn't applied per key Mon, 02 Oct, 09:41
Federico D'Ambrosio How to deal with blocking calls inside a Sink? Mon, 02 Oct, 09:53
Federico D'Ambrosio Re: ArrayIndexOutOfBoundExceptions while processing valve output watermark and while applying ReduceFunction in reducing state Mon, 02 Oct, 09:57
Timo Walther Re: Enriching data from external source with cache Mon, 02 Oct, 10:07
Timo Walther Re: How to deal with blocking calls inside a Sink? Mon, 02 Oct, 10:17
Marchant, Hayden In-memory cache Mon, 02 Oct, 10:46
Björn Zachrisson Flink Watermark and timing Mon, 02 Oct, 11:06
yunfan123 Re: How flink monitor source stream task(Time Trigger) is running? Mon, 02 Oct, 11:19
Federico D'Ambrosio Re: How to deal with blocking calls inside a Sink? Mon, 02 Oct, 11:19
Stavros Kontopoulos Re: In-memory cache Mon, 02 Oct, 11:24
r. r. Re: how many 'run -c' commands to start? Mon, 02 Oct, 12:10
Bo Yu Fwd: Consult about flink on mesos cluster Mon, 02 Oct, 12:49
Marchant, Hayden RE: In-memory cache Mon, 02 Oct, 13:02
Antoine Philippot Avoid duplicate messages while restarting a job for an application upgrade Mon, 02 Oct, 13:35
ant burton Savepoints - jobmanager.rpc.address Mon, 02 Oct, 13:39
Garrett Barton At end of complex parallel flow, how to force end step with parallel=1? Mon, 02 Oct, 13:46
ant burton Session Window set max timeout Mon, 02 Oct, 14:42
Piotr Nowojski Re: Avoid duplicate messages while restarting a job for an application upgrade Mon, 02 Oct, 14:50
Antoine Philippot Re: Avoid duplicate messages while restarting a job for an application upgrade Mon, 02 Oct, 15:30
Derek VerLee Re: Enriching data from external source with cache Mon, 02 Oct, 16:30
r. r. kafka consumer parallelism Mon, 02 Oct, 16:46
Piotr Nowojski Re: Avoid duplicate messages while restarting a job for an application upgrade Mon, 02 Oct, 17:09
Timo Walther Re: Flink Watermark and timing Mon, 02 Oct, 17:28
Timo Walther Re: Session Window set max timeout Mon, 02 Oct, 17:50
Timo Walther Re: kafka consumer parallelism Mon, 02 Oct, 17:59
Tony Wei Re: Stream Task seems to be blocked after checkpoint timeout Tue, 03 Oct, 05:26
vipul singh Weird error in submitting a flink job to yarn cluster Tue, 03 Oct, 06:01
Sofer, Tovi RE: kafka consumer parallelism Tue, 03 Oct, 07:34
Stefan Richter Re: Stream Task seems to be blocked after checkpoint timeout Tue, 03 Oct, 08:01
Gábor Gévay Re: At end of complex parallel flow, how to force end step with parallel=1? Tue, 03 Oct, 08:12
Tony Wei Re: Stream Task seems to be blocked after checkpoint timeout Tue, 03 Oct, 08:25
Carst Tankink Re: kafka consumer parallelism Tue, 03 Oct, 08:30
nragon Re: Sink buffering Tue, 03 Oct, 09:31
Tay Zhen Shen Fw: Question on Flink on Window Tue, 03 Oct, 10:19
Rahul Raj Custom Metrics Reporting in Flink Tue, 03 Oct, 11:51
Stefan Richter Re: Stream Task seems to be blocked after checkpoint timeout Tue, 03 Oct, 15:38
Hao Sun javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated for S3 access Tue, 03 Oct, 18:48
Garrett Barton Re: At end of complex parallel flow, how to force end step with parallel=1? Tue, 03 Oct, 19:57
Chesnay Schepler Re: Custom Metrics Reporting in Flink Tue, 03 Oct, 20:40
Aniket Deshpande [No Subject] Wed, 04 Oct, 01:08
Aniket Deshpande Classloader error after SSL setup Wed, 04 Oct, 01:15
Piotr Nowojski Re: How flink monitor source stream task(Time Trigger) is running? Wed, 04 Oct, 07:27
Piotr Nowojski Re: Sink buffering Wed, 04 Oct, 08:06
nragon Re: Sink buffering Wed, 04 Oct, 08:30
Piotr Nowojski Re: Sink buffering Wed, 04 Oct, 10:29
r. r. Re: kafka consumer parallelism Wed, 04 Oct, 10:36
nragon Re: Sink buffering Wed, 04 Oct, 10:45
Stephan Ewen Re: History Server Wed, 04 Oct, 10:49
Stephan Ewen Re: Noisy org.apache.flink.configuration.GlobalConfiguration Wed, 04 Oct, 10:50
Fabian Hueske Re: At end of complex parallel flow, how to force end step with parallel=1? Wed, 04 Oct, 12:01
Chesnay Schepler Re: Classloader error after SSL setup Wed, 04 Oct, 12:11
Chesnay Schepler Re: Classloader error after SSL setup Wed, 04 Oct, 12:15
Chesnay Schepler Re: Fw: Question on Flink on Window Wed, 04 Oct, 12:28
Chesnay Schepler Re: Weird error in submitting a flink job to yarn cluster Wed, 04 Oct, 12:47
Piotr Nowojski Re: Sink buffering Wed, 04 Oct, 13:18
nragon Re: Sink buffering Wed, 04 Oct, 13:21
Chesnay Schepler Re: javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated for S3 access Wed, 04 Oct, 15:11
Hao Sun Re: javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated for S3 access Wed, 04 Oct, 15:23
Hao Sun Re: javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated for S3 access Wed, 04 Oct, 15:25
G.S.Vijay Raajaa Custom sliding window Wed, 04 Oct, 19:50
Eron Wright Re: Classloader error after SSL setup Wed, 04 Oct, 20:09
Aniket Deshpande Re: Classloader error after SSL setup Wed, 04 Oct, 20:58
Chesnay Schepler Re: Classloader error after SSL setup Wed, 04 Oct, 21:47
Aniket Deshpande Re: Classloader error after SSL setup Wed, 04 Oct, 22:58
Ken Krugler Unusual log message - Emitter thread got interrupted Wed, 04 Oct, 23:33
Vishal Santoshi Failing to recover once checkpoint fails Thu, 05 Oct, 00:19
Vishal Santoshi Re: Failing to recover once checkpoint fails Thu, 05 Oct, 00:20
Carst Tankink Re: kafka consumer parallelism Thu, 05 Oct, 06:04
mrooding Re: Savepoints and migrating value state data types Thu, 05 Oct, 08:39
Fabian Hueske Re: Failing to recover once checkpoint fails Thu, 05 Oct, 09:01
Rahul Raj Calculating metrics real time Thu, 05 Oct, 10:57
Yunus Olgun Kafka Producer writeToKafkaWithTimestamps; name, uid, parallelism fails Thu, 05 Oct, 11:38
Fabian Hueske Re: Calculating metrics real time Thu, 05 Oct, 12:20
Fabian Hueske Re: Kafka Producer writeToKafkaWithTimestamps; name, uid, parallelism fails Thu, 05 Oct, 12:33
Rahul Raj Re: Calculating metrics real time Thu, 05 Oct, 12:41
Fabian Hueske Re: Calculating metrics real time Thu, 05 Oct, 12:43
Vishal Santoshi Re: Failing to recover once checkpoint fails Thu, 05 Oct, 12:56
Vishal Santoshi Re: Failing to recover once checkpoint fails Thu, 05 Oct, 13:26
r. r. Re: kafka consumer parallelism Thu, 05 Oct, 13:49
Vishal Santoshi Re: Failing to recover once checkpoint fails Thu, 05 Oct, 14:13
Vishal Santoshi Re: Failing to recover once checkpoint fails Thu, 05 Oct, 14:57
Vishal Santoshi Re: Failing to recover once checkpoint fails Thu, 05 Oct, 15:40
Ajay Krishna Re: Issue with CEP library Thu, 05 Oct, 17:00
Garrett Barton Re: At end of complex parallel flow, how to force end step with parallel=1? Thu, 05 Oct, 21:21
Aljoscha Krettek Re: Failing to recover once checkpoint fails Fri, 06 Oct, 06:36
Fabian Hueske Re: At end of complex parallel flow, how to force end step with parallel=1? Fri, 06 Oct, 07:09
Tzu-Li (Gordon) Tai Re: Savepoints - jobmanager.rpc.address Fri, 06 Oct, 08:43
Tzu-Li (Gordon) Tai Re: Fwd: Consult about flink on mesos cluster Fri, 06 Oct, 08:54
Tzu-Li (Gordon) Tai Re: Programmatic configuration Fri, 06 Oct, 09:08
Aljoscha Krettek Re: Custom sliding window Fri, 06 Oct, 09:16
Tzu-Li (Gordon) Tai Re: Savepoints and migrating value state data types Fri, 06 Oct, 09:39
r. r. keep-alive job strategy Fri, 06 Oct, 11:56
Jose Miguel Tejedor Fernandez Lost data when resuming from savepoint Fri, 06 Oct, 13:48
Vishal Santoshi Re: Failing to recover once checkpoint fails Fri, 06 Oct, 13:59
Aljoscha Krettek Re: CustomPartitioner that simulates ForwardPartitioner and watermarks Fri, 06 Oct, 14:48
Karthik Deivasigamani Checkpoint was declined (tasks not ready) Fri, 06 Oct, 14:52
Karthik Deivasigamani Re: Checkpoint was declined (tasks not ready) Fri, 06 Oct, 14:53
Karthik Deivasigamani async io operator timeouts Fri, 06 Oct, 14:57
Fabian Hueske Re: Unusual log message - Emitter thread got interrupted Fri, 06 Oct, 16:17
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Sep 2019364
Aug 2019627
Jul 2019635
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