flink-user mailing list archives: July 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Vishnu Viswanath Re: maximum size of window Fri, 01 Jul, 00:53
Chia-Hung Lin Is it possible to restart only the function that fails instead of entire job? Fri, 01 Jul, 07:18
Ufuk Celebi Re: Is it possible to restart only the function that fails instead of entire job? Fri, 01 Jul, 08:26
Josh Re: How to avoid breaking states when upgrading Flink job? Fri, 01 Jul, 09:21
Flavio Pompermaier Different results on local and on cluster Fri, 01 Jul, 12:17
Ryan Crumley Using standalone single node without HA in production, crazy? Fri, 01 Jul, 13:41
Josh Re: How to avoid breaking states when upgrading Flink job? Fri, 01 Jul, 14:26
Aljoscha Krettek Re: Flink streaming connect and split streams Fri, 01 Jul, 15:56
Aljoscha Krettek Re: How to avoid breaking states when upgrading Flink job? Fri, 01 Jul, 16:01
Aljoscha Krettek Re: Different results on local and on cluster Fri, 01 Jul, 16:58
Flavio Pompermaier Re: Different results on local and on cluster Fri, 01 Jul, 17:05
vpra...@gmail.com Failed job restart - flink on yarn Fri, 01 Jul, 20:34
Jamie Grier Re: Flink for historical time series processing Fri, 01 Jul, 22:54
Jamie Grier Re: Error submitting stand-alone Flink job to EMR YARN cluster Fri, 01 Jul, 23:21
Jamie Grier Re: Failed job restart - flink on yarn Fri, 01 Jul, 23:35
Jamie Grier Re: Using standalone single node without HA in production, crazy? Sat, 02 Jul, 00:22
Saliya Ekanayake Re: Parameters to Control Intra-node Parallelism Sat, 02 Jul, 01:26
Ryan Crumley Re: Using standalone single node without HA in production, crazy? Sat, 02 Jul, 03:05
vpra...@gmail.com Re: Failed job restart - flink on yarn Sat, 02 Jul, 05:09
Ufuk Celebi Re: Parameters to Control Intra-node Parallelism Sat, 02 Jul, 15:08
Saliya Ekanayake Re: Parameters to Control Intra-node Parallelism Sat, 02 Jul, 15:12
Ufuk Celebi Re: Parameters to Control Intra-node Parallelism Sat, 02 Jul, 15:22
Saliya Ekanayake Re: Parameters to Control Intra-node Parallelism Sat, 02 Jul, 16:28
Biplob Biswas Data point goes missing within iteration Sun, 03 Jul, 14:26
Ufuk Celebi Re: Parameters to Control Intra-node Parallelism Sun, 03 Jul, 15:28
Saliya Ekanayake Re: Parameters to Control Intra-node Parallelism Sun, 03 Jul, 15:34
Jamie Grier Re: Error submitting stand-alone Flink job to EMR YARN cluster Sun, 03 Jul, 16:04
Yukun Guo Tumbling time window cannot group events properly Mon, 04 Jul, 04:00
Aljoscha Krettek Re: Tumbling time window cannot group events properly Mon, 04 Jul, 08:15
Ufuk Celebi Re: Error submitting stand-alone Flink job to EMR YARN cluster Mon, 04 Jul, 09:44
Adrian Bartnik Flink programm with for loop yields wrong results when run in parallel Mon, 04 Jul, 09:56
Ufuk Celebi Re: Failed job restart - flink on yarn Mon, 04 Jul, 09:57
Ufuk Celebi Re: Using standalone single node without HA in production, crazy? Mon, 04 Jul, 10:04
Ufuk Celebi Re: Different results on local and on cluster Mon, 04 Jul, 10:06
Biplob Biswas Re: Data point goes missing within iteration Mon, 04 Jul, 10:07
Ufuk Celebi Re: How to avoid breaking states when upgrading Flink job? Mon, 04 Jul, 10:10
Ufuk Celebi Re: Documentation for translation of Job graph to Execution graph Mon, 04 Jul, 10:13
Flavio Pompermaier Re: Different results on local and on cluster Mon, 04 Jul, 10:23
Ufuk Celebi Re: Flink programm with for loop yields wrong results when run in parallel Mon, 04 Jul, 10:24
Ufuk Celebi Re: Different results on local and on cluster Mon, 04 Jul, 10:28
Flavio Pompermaier Re: Flink programm with for loop yields wrong results when run in parallel Mon, 04 Jul, 10:30
Flavio Pompermaier Re: Different results on local and on cluster Mon, 04 Jul, 10:34
Flavio Pompermaier Re: Different results on local and on cluster Mon, 04 Jul, 10:34
Ufuk Celebi Re: Data point goes missing within iteration Mon, 04 Jul, 10:57
Yukun Guo Re: Tumbling time window cannot group events properly Mon, 04 Jul, 11:20
Biplob Biswas Re: Data point goes missing within iteration Mon, 04 Jul, 12:53
Aljoscha Krettek Re: Tumbling time window cannot group events properly Mon, 04 Jul, 13:41
Stephan Ewen Re: Flink 1.0 Critical memory issue/leak with a high throughput stream Mon, 04 Jul, 15:17
Ryan Crumley Re: Using standalone single node without HA in production, crazy? Mon, 04 Jul, 18:50
Yukun Guo Re: Tumbling time window cannot group events properly Tue, 05 Jul, 02:35
#ZHANG SHUHAO# custom scheduler in Flink? Tue, 05 Jul, 03:12
Hironori Ogibayashi Re: Checkpoint takes long with FlinkKafkaConsumer Tue, 05 Jul, 07:24
Stephan Ewen Re: Checkpoint takes long with FlinkKafkaConsumer Tue, 05 Jul, 08:04
madhu phatak Timewindow watermarks specific to keys of stream Tue, 05 Jul, 08:14
Harikrishnan S Re: JDBC sink in flink Tue, 05 Jul, 08:41
Flavio Pompermaier Re: JDBC sink in flink Tue, 05 Jul, 08:52
Soumya Simanta Re: Flink 1.0 Critical memory issue/leak with a high throughput stream Tue, 05 Jul, 09:02
Stefano Bortoli Re: JDBC sink in flink Tue, 05 Jul, 09:11
Aljoscha Krettek Re: Tumbling time window cannot group events properly Tue, 05 Jul, 09:37
Harikrishnan S Re: JDBC sink in flink Tue, 05 Jul, 10:01
Harikrishnan S Re: JDBC sink in flink Tue, 05 Jul, 10:04
Chesnay Schepler Re: JDBC sink in flink Tue, 05 Jul, 10:23
Harikrishnan S Re: JDBC sink in flink Tue, 05 Jul, 10:51
Chesnay Schepler Re: JDBC sink in flink Tue, 05 Jul, 10:58
Harikrishnan S Re: JDBC sink in flink Tue, 05 Jul, 11:27
Andres R. Masegosa disable console output Tue, 05 Jul, 12:13
Stefano Bortoli Re: JDBC sink in flink Tue, 05 Jul, 12:20
Nguyen Xuan Truong Flink stops deploying jobs on normal iteration Tue, 05 Jul, 15:11
Daniel Li Re: Switch to skip the stream alignment during a checkpoint? Tue, 05 Jul, 15:57
Daniel Li Re: Checkpointing very large state in RocksDB? Tue, 05 Jul, 16:01
Boden, Christoph Parameters inside an iteration? Tue, 05 Jul, 16:16
Vasiliki Kalavri Re: Parameters inside an iteration? Tue, 05 Jul, 18:42
Vasiliki Kalavri Re: Flink stops deploying jobs on normal iteration Tue, 05 Jul, 18:46
Vishnu Viswanath Re: Checkpointing very large state in RocksDB? Tue, 05 Jul, 19:07
Nguyen Xuan Truong Re: Flink stops deploying jobs on normal iteration Tue, 05 Jul, 19:48
Ufuk Celebi Re: Data point goes missing within iteration Tue, 05 Jul, 20:22
Gyula Fóra Kafka Producer Partitioning issue Tue, 05 Jul, 22:01
Chen Qin Late arriving events Tue, 05 Jul, 23:06
vpra...@gmail.com Re: Failed job restart - flink on yarn Tue, 05 Jul, 23:18
Jamie Grier Re: Late arriving events Wed, 06 Jul, 02:01
Jamie Grier Re: Failed job restart - flink on yarn Wed, 06 Jul, 02:18
Jamie Grier Re: disable console output Wed, 06 Jul, 02:32
Jamie Grier Re: Timewindow watermarks specific to keys of stream Wed, 06 Jul, 02:35
agentmilindu Re: Graph with stream of updates Wed, 06 Jul, 06:07
Biplob Biswas Re: Data point goes missing within iteration Wed, 06 Jul, 07:35
Aljoscha Krettek Re: Checkpointing very large state in RocksDB? Wed, 06 Jul, 09:02
Yukun Guo Re: Tumbling time window cannot group events properly Wed, 06 Jul, 09:05
Aljoscha Krettek Re: [DISCUSS] Allowed Lateness in Flink Wed, 06 Jul, 13:19
subash basnet Streaming Exception error message Explanation Wed, 06 Jul, 13:35
David Olsen Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'? Wed, 06 Jul, 13:43
Radu Tudoran Flink and Calcite Wed, 06 Jul, 13:49
Márton Balassi Re: Flink and Calcite Wed, 06 Jul, 14:00
Kostas Kloudas Re: Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'? Wed, 06 Jul, 14:39
Ufuk Celebi Re: Data point goes missing within iteration Wed, 06 Jul, 15:55
Chen Qin Re: Late arriving events Wed, 06 Jul, 23:17
Saliya Ekanayake Re: Parameters to Control Intra-node Parallelism Thu, 07 Jul, 05:34
madhu phatak Re: Timewindow watermarks specific to keys of stream Thu, 07 Jul, 06:22
Vasiliki Kalavri Re: Flink stops deploying jobs on normal iteration Thu, 07 Jul, 08:17
Ufuk Celebi Re: Parameters to Control Intra-node Parallelism Thu, 07 Jul, 08:27
Vasiliki Kalavri Re: Graph with stream of updates Thu, 07 Jul, 08:28
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
May 2019325
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