flink-user mailing list archives: July 2016

Site index · List index
Message list1 · 2 · 3 · Next »Thread · Author · Date
Re: maximum size of window
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
Re: How to avoid breaking states when upgrading Flink job?
Josh   Re: How to avoid breaking states when upgrading Flink job? Fri, 01 Jul, 09:21
Josh     Re: How to avoid breaking states when upgrading Flink job? Fri, 01 Jul, 14:26
Aljoscha Krettek       Re: How to avoid breaking states when upgrading Flink job? Fri, 01 Jul, 16:01
Ufuk Celebi         Re: How to avoid breaking states when upgrading Flink job? Mon, 04 Jul, 10:10
simon peyer   Accessing external DB inside RichFlatMap Function Thu, 07 Jul, 08:38
Kostas Kloudas     Re: Accessing external DB inside RichFlatMap Function Thu, 07 Jul, 08:58
Chesnay Schepler       Re: Accessing external DB inside RichFlatMap Function Thu, 07 Jul, 09:03
Kostas Kloudas         Re: Accessing external DB inside RichFlatMap Function Thu, 07 Jul, 09:05
Flavio Pompermaier Different results on local and on cluster Fri, 01 Jul, 12:17
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
Ufuk Celebi       Re: Different results on local and on cluster Mon, 04 Jul, 10:06
Flavio Pompermaier         Re: Different results on local and on cluster Mon, 04 Jul, 10:23
Ufuk Celebi           Re: Different results on local and on cluster Mon, 04 Jul, 10:28
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
Flavio Pompermaier                 Re: Different results on local and on cluster Mon, 18 Jul, 08:13
Ufuk Celebi                   Re: Different results on local and on cluster Mon, 18 Jul, 09:28
Ryan Crumley Using standalone single node without HA in production, crazy? Fri, 01 Jul, 13:41
Jamie Grier   Re: Using standalone single node without HA in production, crazy? Sat, 02 Jul, 00:22
Ryan Crumley     Re: Using standalone single node without HA in production, crazy? Sat, 02 Jul, 03:05
Ufuk Celebi   Re: Using standalone single node without HA in production, crazy? Mon, 04 Jul, 10:04
Ryan Crumley     Re: Using standalone single node without HA in production, crazy? Mon, 04 Jul, 18:50
Re: Flink streaming connect and split streams
Aljoscha Krettek   Re: Flink streaming connect and split streams Fri, 01 Jul, 15:56
vpra...@gmail.com Failed job restart - flink on yarn Fri, 01 Jul, 20:34
Jamie Grier   Re: Failed job restart - flink on yarn Fri, 01 Jul, 23:35
vpra...@gmail.com     Re: Failed job restart - flink on yarn Sat, 02 Jul, 05:09
Ufuk Celebi       Re: Failed job restart - flink on yarn Mon, 04 Jul, 09:57
vpra...@gmail.com         Re: Failed job restart - flink on yarn Tue, 05 Jul, 23:18
Jamie Grier           Re: Failed job restart - flink on yarn Wed, 06 Jul, 02:18
Re: Flink for historical time series processing
Jamie Grier   Re: Flink for historical time series processing Fri, 01 Jul, 22:54
Re: Error submitting stand-alone Flink job to EMR YARN cluster
Jamie Grier   Re: Error submitting stand-alone Flink job to EMR YARN cluster Fri, 01 Jul, 23:21
Jamie Grier   Re: Error submitting stand-alone Flink job to EMR YARN cluster Sun, 03 Jul, 16:04
Ufuk Celebi     Re: Error submitting stand-alone Flink job to EMR YARN cluster Mon, 04 Jul, 09:44
Re: Parameters to Control Intra-node Parallelism
Saliya Ekanayake   Re: Parameters to Control Intra-node Parallelism Sat, 02 Jul, 01:26
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
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
Saliya Ekanayake               Re: Parameters to Control Intra-node Parallelism Thu, 07 Jul, 05:34
Ufuk Celebi                 Re: Parameters to Control Intra-node Parallelism Thu, 07 Jul, 08:27
Saliya Ekanayake                   Re: Parameters to Control Intra-node Parallelism Thu, 07 Jul, 15:46
Robert Metzger                     Re: Parameters to Control Intra-node Parallelism Fri, 08 Jul, 16:31
Saliya Ekanayake                       Re: Parameters to Control Intra-node Parallelism Fri, 08 Jul, 16:46
Greg Hogan                         Re: Parameters to Control Intra-node Parallelism Mon, 11 Jul, 00:45
Saliya Ekanayake                         Re: Parameters to Control Intra-node Parallelism Mon, 11 Jul, 03:55
Greg Hogan                           Re: Parameters to Control Intra-node Parallelism Mon, 11 Jul, 15:34
Saliya Ekanayake                             Re: Parameters to Control Intra-node Parallelism Mon, 11 Jul, 15:49
Ovidiu-Cristian MARCU                               Re: Parameters to Control Intra-node Parallelism Tue, 12 Jul, 11:39
Saliya Ekanayake                                 Re: Parameters to Control Intra-node Parallelism Tue, 12 Jul, 19:18
Ovidiu-Cristian MARCU                                   Re: Parameters to Control Intra-node Parallelism Wed, 13 Jul, 19:34
Saliya Ekanayake                                     Re: Parameters to Control Intra-node Parallelism Thu, 14 Jul, 19:23
Biplob Biswas Data point goes missing within iteration Sun, 03 Jul, 14:26
Biplob Biswas   Re: Data point goes missing within iteration Mon, 04 Jul, 10:07
Ufuk Celebi     Re: Data point goes missing within iteration Mon, 04 Jul, 10:57
Biplob Biswas       Re: Data point goes missing within iteration Mon, 04 Jul, 12:53
Ufuk Celebi         Re: Data point goes missing within iteration Tue, 05 Jul, 20:22
Biplob Biswas           Re: Data point goes missing within iteration Wed, 06 Jul, 07:35
Ufuk Celebi             Re: Data point goes missing within iteration Wed, 06 Jul, 15:55
Ufuk Celebi               Re: Data point goes missing within iteration Wed, 13 Jul, 10:40
Biplob Biswas                 Re: Data point goes missing within iteration Wed, 13 Jul, 13:54
Biplob Biswas                   Re: Data point goes missing within iteration Tue, 19 Jul, 08:15
Ufuk Celebi                     Re: Data point goes missing within iteration Tue, 19 Jul, 09:50
Biplob Biswas                       Re: Data point goes missing within iteration Tue, 19 Jul, 09:43
Maximilian Michels                         Re: Data point goes missing within iteration Wed, 20 Jul, 09:57
Paris Carbone                           Re: Data point goes missing within iteration Wed, 20 Jul, 10:30
Maximilian Michels                             Re: Data point goes missing within iteration Wed, 20 Jul, 11:42
Biplob Biswas                               Re: Data point goes missing within iteration Wed, 20 Jul, 13:41
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
Yukun Guo     Re: Tumbling time window cannot group events properly Mon, 04 Jul, 11:20
Aljoscha Krettek       Re: Tumbling time window cannot group events properly Mon, 04 Jul, 13:41
Yukun Guo         Re: Tumbling time window cannot group events properly Tue, 05 Jul, 02:35
Aljoscha Krettek           Re: Tumbling time window cannot group events properly Tue, 05 Jul, 09:37
Yukun Guo             Re: Tumbling time window cannot group events properly Wed, 06 Jul, 09:05
Adrian Bartnik Flink programm with for loop yields wrong results when run in parallel Mon, 04 Jul, 09:56
Ufuk Celebi   Re: Flink programm with for loop yields wrong results when run in parallel Mon, 04 Jul, 10:24
Flavio Pompermaier     Re: Flink programm with for loop yields wrong results when run in parallel Mon, 04 Jul, 10:30
Re: Documentation for translation of Job graph to Execution graph
Ufuk Celebi   Re: Documentation for translation of Job graph to Execution graph Mon, 04 Jul, 10:13
Re: Flink 1.0 Critical memory issue/leak with a high throughput stream
Stephan Ewen   Re: Flink 1.0 Critical memory issue/leak with a high throughput stream Mon, 04 Jul, 15:17
Soumya Simanta     Re: Flink 1.0 Critical memory issue/leak with a high throughput stream Tue, 05 Jul, 09:02
#ZHANG SHUHAO# custom scheduler in Flink? Tue, 05 Jul, 03:12
Aljoscha Krettek   Re: custom scheduler in Flink? Wed, 13 Jul, 09:59
Re: Checkpoint takes long with FlinkKafkaConsumer
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
Hironori Ogibayashi       Re: Checkpoint takes long with FlinkKafkaConsumer Fri, 08 Jul, 10:21
madhu phatak Timewindow watermarks specific to keys of stream Tue, 05 Jul, 08:14
Jamie Grier   Re: Timewindow watermarks specific to keys of stream Wed, 06 Jul, 02:35
madhu phatak     Re: Timewindow watermarks specific to keys of stream Thu, 07 Jul, 06:22
Re: JDBC sink in flink
Harikrishnan S   Re: JDBC sink in flink Tue, 05 Jul, 08:41
Flavio Pompermaier     Re: JDBC sink in flink Tue, 05 Jul, 08:52
Stefano Bortoli       Re: JDBC sink in flink Tue, 05 Jul, 09:11
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
Stefano Bortoli                 Re: JDBC sink in flink Tue, 05 Jul, 12:20
Andres R. Masegosa disable console output Tue, 05 Jul, 12:13
Jamie Grier   Re: disable console output Wed, 06 Jul, 02:32
Nguyen Xuan Truong Flink stops deploying jobs on normal iteration Tue, 05 Jul, 15:11
Vasiliki Kalavri   Re: Flink stops deploying jobs on normal iteration Tue, 05 Jul, 18:46
Nguyen Xuan Truong     Re: Flink stops deploying jobs on normal iteration Tue, 05 Jul, 19:48
Vasiliki Kalavri       Re: Flink stops deploying jobs on normal iteration Thu, 07 Jul, 08:17
Nguyen Xuan Truong         Re: Flink stops deploying jobs on normal iteration Thu, 07 Jul, 18:28
Re: Switch to skip the stream alignment during a checkpoint?
Daniel Li   Re: Switch to skip the stream alignment during a checkpoint? Tue, 05 Jul, 15:57
Re: Checkpointing very large state in RocksDB?
Daniel Li   Re: Checkpointing very large state in RocksDB? Tue, 05 Jul, 16:01
Vishnu Viswanath   Re: Checkpointing very large state in RocksDB? Tue, 05 Jul, 19:07
Aljoscha Krettek     Re: Checkpointing very large state in RocksDB? Wed, 06 Jul, 09:02
Boden, Christoph Parameters inside an iteration? Tue, 05 Jul, 16:16
Vasiliki Kalavri   Re: Parameters inside an iteration? Tue, 05 Jul, 18:42
Gyula Fóra Kafka Producer Partitioning issue Tue, 05 Jul, 22:01
Robert Metzger   Re: Kafka Producer Partitioning issue Fri, 08 Jul, 11:33
Gyula Fóra     Re: Kafka Producer Partitioning issue Fri, 08 Jul, 13:04
Chen Qin Late arriving events Tue, 05 Jul, 23:06
Jamie Grier   Re: Late arriving events Wed, 06 Jul, 02:01
Chen Qin     Re: Late arriving events Wed, 06 Jul, 23:17
Kostas Kloudas       Re: Late arriving events Thu, 07 Jul, 08:28
Re: Graph with stream of updates
agentmilindu   Re: Graph with stream of updates Wed, 06 Jul, 06:07
Vasiliki Kalavri     Re: Graph with stream of updates Thu, 07 Jul, 08:28
Re: [DISCUSS] Allowed Lateness in Flink
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
Márton Balassi   Re: Streaming Exception error message Explanation Thu, 07 Jul, 09:24
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
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
David Olsen     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(...)'? Fri, 08 Jul, 04:12
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(...)'? Fri, 08 Jul, 08:32
Robert Metzger         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(...)'? Fri, 08 Jul, 09:56
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(...)'? Fri, 08 Jul, 14:39
David Olsen             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(...)'? Sun, 10 Jul, 07:43
Stephan Ewen               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(...)'? Sun, 10 Jul, 16:52
Radu Tudoran Flink and Calcite Wed, 06 Jul, 13:49
Márton Balassi   Re: Flink and Calcite Wed, 06 Jul, 14:00
Stephan Ewen     Re: Flink and Calcite Thu, 07 Jul, 08:40
Bence Ágocsi Kiss Cep NFA formal declaration Thu, 07 Jul, 11:00
Till Rohrmann   Re: Cep NFA formal declaration Thu, 07 Jul, 11:41
adamlehenbauer Adding and removing operations after execute Thu, 07 Jul, 11:25
Kostas Kloudas   Re: Adding and removing operations after execute Thu, 07 Jul, 12:24
Jamie Grier     Re: Adding and removing operations after execute Thu, 07 Jul, 18:34
Aljoscha Krettek       Re: Adding and removing operations after execute Fri, 08 Jul, 08:50
Saliya Ekanayake Flink is Unstable when TM > 1 Fri, 08 Jul, 03:57
Ufuk Celebi   Re: Flink is Unstable when TM > 1 Fri, 08 Jul, 07:49
Yukun Guo Extract type information from SortedMap Fri, 08 Jul, 10:27
Robert Metzger   Re: Extract type information from SortedMap Fri, 08 Jul, 16:25
Yukun Guo     Re: Extract type information from SortedMap Sat, 09 Jul, 09:55
Timo Walther       Re: Extract type information from SortedMap Mon, 11 Jul, 07:22
Saliya Ekanayake Modifying start-cluster scripts to efficiently spawn multiple TMs Sat, 09 Jul, 07:44
Gyula Fóra   Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Sun, 10 Jul, 21:42
Saliya Ekanayake     Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Sun, 10 Jul, 21:55
Greg Hogan   Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 00:33
Saliya Ekanayake     Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 04:02
Greg Hogan       Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 16:15
Saliya Ekanayake         Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 16:19
Saliya Ekanayake           Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 16:19
Saliya Ekanayake             Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 18:59
Greg Hogan               Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 20:53
Saliya Ekanayake                 Re: Modifying start-cluster scripts to efficiently spawn multiple TMs Mon, 11 Jul, 21:08
Sebastian Random access to small global state Sat, 09 Jul, 12:05
Suneel Marthi   Re: Random access to small global state Sat, 09 Jul, 14:03
Robert Metzger     Re: Random access to small global state Thu, 14 Jul, 14:31
Le Quoc Do sampling function Sat, 09 Jul, 14:47
Greg Hogan   Re: sampling function Sat, 09 Jul, 15:43
Kostas Kloudas     Re: sampling function Mon, 11 Jul, 09:31
Vasiliki Kalavri       Re: sampling function Mon, 11 Jul, 09:44
Le Quoc Do         Re: sampling function Mon, 11 Jul, 14:15
Paris Carbone           Re: sampling function Tue, 12 Jul, 10:11
Till Rohrmann             Re: sampling function Tue, 12 Jul, 16:05
Le Quoc Do               Re: sampling function Wed, 13 Jul, 07:25
The two inputs have different execution contexts.
Alieh Saeedi   The two inputs have different execution contexts. Sun, 10 Jul, 13:13
Kostas Kloudas     Re: The two inputs have different execution contexts. Mon, 11 Jul, 09:33
Alieh Saeedi       Re: The two inputs have different execution contexts. Mon, 11 Jul, 09:46
Kostas Kloudas         Re: The two inputs have different execution contexts. Mon, 11 Jul, 09:46
Claudia Wegmann dynamic streams and patterns Mon, 11 Jul, 07:39
Robert Metzger   Re: dynamic streams and patterns Thu, 14 Jul, 14:26
Claudia Wegmann     AW: dynamic streams and patterns Fri, 15 Jul, 10:57
Claudia Wegmann     WG: dynamic streams and patterns Mon, 25 Jul, 08:09
Ufuk Celebi       Re: dynamic streams and patterns Tue, 26 Jul, 11:35
Message list1 · 2 · 3 · Next »Thread · Author · Date
Box list
May 2019362
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