flink-user mailing list archives: February 2018

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Niclas Hedhman Re: Is Flink easy to deploy ? Sat, 24 Feb, 02:25
Nico Kruber Re: Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase Mon, 26 Feb, 17:19
Nico Kruber Re: TaskManager crashes with PageRank algorithm in Gelly Mon, 26 Feb, 17:35
Nico Kruber Re: Which test cluster to use for checkpointing tests? Mon, 26 Feb, 17:41
Nico Kruber Re: Which test cluster to use for checkpointing tests? Wed, 28 Feb, 15:02
Nico Kruber Re: logging question Wed, 28 Feb, 15:55
Niels Managed State Custom Serializer with Avro Mon, 19 Feb, 15:14
Niels Re: Managed State Custom Serializer with Avro Tue, 27 Feb, 07:47
Niels Fat jar fails deployment (streaming job too large) Tue, 27 Feb, 08:31
Niels Re: Fat jar fails deployment (streaming job too large) Tue, 27 Feb, 16:40
Niels Re: Fat jar fails deployment (streaming job too large) Tue, 27 Feb, 16:58
Niels Denissen Re: Managed State Custom Serializer with Avro Mon, 19 Feb, 18:17
Or Sher Re: flink read hdfs file error Thu, 15 Feb, 10:12
Pawel Bartoszek Java heap size in YARN Thu, 15 Feb, 16:03
Pawel Bartoszek Re: Java heap size in YARN Thu, 15 Feb, 17:01
Pawel Bartoszek Re: Java heap size in YARN Thu, 15 Feb, 17:33
Pawel Bartoszek Diagnosing high cpu/memory issue in Flink Thu, 15 Feb, 19:34
Pawel Bartoszek Re: Correlation between number of operators and Job manager memory requirements Sun, 18 Feb, 17:46
Philip Doctor Flink Kafka reads too many bytes .... Very rarely Mon, 26 Feb, 23:02
Philip Doctor Re: Flink Kafka reads too many bytes .... Very rarely Wed, 28 Feb, 04:01
Philip Doctor Re: Flink Kafka reads too many bytes .... Very rarely Wed, 28 Feb, 04:13
Piotr Nowojski Re: Latest version of Kafka Fri, 02 Feb, 14:36
Piotr Nowojski Re: Flink not writing last few elements to disk Mon, 05 Feb, 08:18
Piotr Nowojski Re: Reduce parallelism without network transfer. Mon, 05 Feb, 08:28
Piotr Nowojski Re: Global window keyBy Mon, 05 Feb, 08:40
Piotr Nowojski Re: Getting Key from keyBy() in ProcessFunction Mon, 05 Feb, 08:56
Piotr Nowojski Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:30
Piotr Nowojski Re: Checkpoint is not triggering as per configuration Mon, 05 Feb, 09:33
Piotr Nowojski Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:49
Piotr Nowojski Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:56
Piotr Nowojski Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 10:03
Piotr Nowojski Re: Reduce parallelism without network transfer. Tue, 06 Feb, 08:05
Piotr Nowojski Re: Rebalance to subtasks in same TaskManager instance Tue, 06 Feb, 08:27
Piotr Nowojski Re: Ceph configuration for checkpoints? Tue, 13 Feb, 09:18
Piotr Nowojski Re: Python and Scala Tue, 13 Feb, 13:14
Piotr Nowojski Re: Python and Scala Wed, 14 Feb, 08:54
Piotr Nowojski Re: Python and Scala Wed, 14 Feb, 09:28
Puneet Kinra Re: How to enable “upsert mode” for dynamic tables? Thu, 01 Feb, 05:08
Puneet Kinra Batch Cascade application Fri, 09 Feb, 09:43
Puneet Kinra Re: Batch Cascade application Fri, 09 Feb, 10:03
Puneet Kinra No Job is getting Submitted through Flink 4.0 UI Fri, 09 Feb, 11:40
Puneet Kinra Re: No Job is getting Submitted through Flink 4.0 UI Fri, 09 Feb, 12:15
Puneet Kinra Unable to submit job from the web UI in flink 4.0 Sat, 10 Feb, 11:51
Puneet Kinra Re: Unable to submit job from the web UI in flink 4.0 Wed, 14 Feb, 07:37
Raja.Aravapalli Flink on YARN || Monitoring REST API Not Working || Please help Thu, 01 Feb, 02:36
Raja.Aravapalli Re: [EXTERNAL] Re: Flink on YARN || Monitoring REST API Not Working || Please help Thu, 01 Feb, 03:24
Raja.Aravapalli Flink REST API Thu, 01 Feb, 20:29
Raja.Aravapalli Re: [EXTERNAL] Re: Flink REST API Fri, 09 Feb, 14:54
Raja.Aravapalli Re: [EXTERNAL] Re: Flink REST API Fri, 09 Feb, 15:46
Ricardo Dinis Question about the need of consumer groups from kafka Fri, 16 Feb, 13:05
Rich Bowen Save the date: ApacheCon North America, September 24-27 in Montréal Tue, 20 Feb, 14:21
Sahil Arora Optimizing multiple aggregate queries on a CEP using Flink Fri, 09 Feb, 22:28
Sahil Arora Re: Optimizing multiple aggregate queries on a CEP using Flink Thu, 15 Feb, 10:12
Sahil Arora Re: Optimizing multiple aggregate queries on a CEP using Flink Thu, 15 Feb, 19:59
Seth Wiesman Re: 'Custom' mapping function on keyed WindowedStream Mon, 26 Feb, 15:25
Shailesh Jain Correlation between number of operators and Job manager memory requirements Sat, 17 Feb, 12:23
Shailesh Jain Re: Correlation between number of operators and Job manager memory requirements Sat, 17 Feb, 12:26
Shailesh Jain Re: Correlation between number of operators and Job manager memory requirements Mon, 19 Feb, 10:35
Shailesh Jain Re: Correlation between number of operators and Job manager memory requirements Tue, 20 Feb, 10:23
Shailesh Jain Re: Correlation between number of operators and Job manager memory requirements Tue, 20 Feb, 15:38
Sharan F FINAL REMINDER: CFP for Apache EU Roadshow Closes 25th February Wed, 21 Feb, 17:18
Sofer, Tovi kafka as recovery only source Tue, 06 Feb, 14:31
Sofer, Tovi RE: kafka as recovery only source Wed, 07 Feb, 13:30
Stavros Kontopoulos Re: Two issues when deploying Flink on DC/OS Thu, 08 Feb, 10:58
Stefan Richter Re: RocksDB / checkpoint questions Mon, 05 Feb, 10:31
Stefan Richter Re: Get which key groups are assigned to an operator Tue, 20 Feb, 13:42
Stefan Richter Re: Get which key groups are assigned to an operator Tue, 20 Feb, 14:56
Stephan Ewen Re: [ANNOUNCE] Apache Flink 1.4.1 released Mon, 19 Feb, 10:30
Steven Wu Re: Joining data in Streaming Tue, 06 Feb, 01:46
Sugandha Amatya Flink job stops when reading file from FTP Sun, 25 Feb, 06:04
Supun Kamburugamuve Slow Flink program Wed, 28 Feb, 16:20
Swapnil Dharane Share Spring Application context among operators Sat, 10 Feb, 04:15
Swapnil Dharane Re: Share Spring Application context among operators Mon, 12 Feb, 04:44
Tay Zhen Shen Implementing CountWindow in Window Join and continuous joining for 2 datastreams Sat, 24 Feb, 06:58
Teena Kappen // BPRISE RE: Multiple Elasticsearch sinks not working in Flink Thu, 01 Feb, 13:42
Teena Kappen // BPRISE RE: Multiple Elasticsearch sinks not working in Flink Sat, 03 Feb, 08:37
Teena Kappen // BPRISE Variable time gap in Session Window Sat, 17 Feb, 07:01
Theodore Vasiloudis Re: Machine Learning: Flink and MOA Sat, 24 Feb, 00:03
Till Rohrmann Re: Task Manager detached under load Mon, 05 Feb, 10:55
Till Rohrmann Re: Two issues when deploying Flink on DC/OS Fri, 09 Feb, 09:06
Till Rohrmann Re: Developing and running Flink applications in Linux through Windows editors or IDE's ? Fri, 09 Feb, 09:10
Till Rohrmann Re: dataset sort Fri, 09 Feb, 09:35
Till Rohrmann Re: Flink batch job stalls on Yarn ... Fri, 09 Feb, 09:50
Till Rohrmann Re: Batch Cascade application Fri, 09 Feb, 09:53
Till Rohrmann Re: Flink batch job stalls on Yarn ... Sat, 10 Feb, 21:44
Till Rohrmann Re: Manipulating Processing elements of Network Buffers Mon, 19 Feb, 10:01
Till Rohrmann Re: Regarding BucketingSink Mon, 19 Feb, 15:37
Till Rohrmann Re: Concurrent modification Exception when submitting multiple jobs Mon, 19 Feb, 15:40
Till Rohrmann Re: Question about the need of consumer groups from kafka Mon, 19 Feb, 15:46
Till Rohrmann Re: Regarding Task Slots allocation Mon, 19 Feb, 15:48
Till Rohrmann Re: Diagnosing high cpu/memory issue in Flink Mon, 19 Feb, 16:08
Till Rohrmann Re: Iterating over state entries Mon, 19 Feb, 16:14
Till Rohrmann Re: A "per operator instance" window all ? Mon, 19 Feb, 16:40
Till Rohrmann Re: Correlation between number of operators and Job manager memory requirements Mon, 19 Feb, 16:48
Till Rohrmann Re: Stopping a kafka consumer gracefully (no losing of inflight events, StoppableFunction) Mon, 19 Feb, 16:50
Till Rohrmann Re: Managed State Custom Serializer with Avro Mon, 19 Feb, 18:09
Till Rohrmann Re: Correlation between number of operators and Job manager memory requirements Tue, 20 Feb, 11:16
Till Rohrmann Re: Managed State Custom Serializer with Avro Tue, 20 Feb, 11:34
Till Rohrmann Re: Stopping a kafka consumer gracefully (no losing of inflight events, StoppableFunction) Wed, 21 Feb, 09:26
Till Rohrmann Re: Stopping a kafka consumer gracefully (no losing of inflight events, StoppableFunction) Wed, 21 Feb, 09:27
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Sep 2019391
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