flink-user mailing list archives: October 2017

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