flink-user mailing list archives: November 2016

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Aljoscha Krettek Re: Order by which windows are processed on event time Mon, 14 Nov, 14:29
Aljoscha Krettek Re: get trigger context from WindowFunction Mon, 14 Nov, 14:31
Aljoscha Krettek Re: apply with fold- and window function Mon, 14 Nov, 14:34
kaelumania Re: Maintaining watermarks per key, instead of per operator instance Mon, 14 Nov, 14:36
Aljoscha Krettek Re: Processing streams of events with unpredictable delays Mon, 14 Nov, 15:21
PACE, JAMES RE: Flink - Nifi Connectors - Class not found Mon, 14 Nov, 15:24
Aljoscha Krettek Re: Re: Lot of RocksDB files in tmp Directory Mon, 14 Nov, 15:31
Gyula Fóra Proper way of adding external jars Mon, 14 Nov, 15:59
Meghashyam Sandeep V map is not executed when using 'bin/flink run' Mon, 14 Nov, 16:19
Geoffrey Mon Re: Many operations cause StackOverflowError with AWS EMR YARN cluster Mon, 14 Nov, 16:38
Miguel Coimbra Re: Too few memory segments provided. Hash Table needs at least 33 memory segments. Mon, 14 Nov, 17:33
Scott Kidder Re: Proper way of adding external jars Mon, 14 Nov, 17:49
Aljoscha Krettek Re: Maintaining watermarks per key, instead of per operator instance Mon, 14 Nov, 18:05
otherwise777 Retrieving values from a dataset of datasets Mon, 14 Nov, 19:44
Petr Novotnik Re: WindowOperator - element's timestamp Mon, 14 Nov, 20:53
Anchit Jatana Re: apply with fold- and window function Tue, 15 Nov, 00:17
Satish Chandra Gupta Re: Flink job restart at checkpoint interval Tue, 15 Nov, 02:24
Dromit Why use Kafka after all? Tue, 15 Nov, 07:14
Stephan Epping Re: Maintaining watermarks per key, instead of per operator instance Tue, 15 Nov, 08:09
Gyula Fóra Re: Proper way of adding external jars Tue, 15 Nov, 09:06
Gábor Gévay Re: Retrieving values from a dataset of datasets Tue, 15 Nov, 10:07
Till Rohrmann Re: map is not executed when using 'bin/flink run' Tue, 15 Nov, 10:20
Felix Neutatz Re: Csv to windows? Tue, 15 Nov, 10:24
Till Rohrmann Re: Flink job restart at checkpoint interval Tue, 15 Nov, 10:31
Till Rohrmann Re: Why use Kafka after all? Tue, 15 Nov, 10:43
Aljoscha Krettek Re: WindowOperator - element's timestamp Tue, 15 Nov, 12:05
Till Rohrmann Re: Proper way of adding external jars Tue, 15 Nov, 13:55
Dominique Rondé Data Loss in HDFS after Job failure Tue, 15 Nov, 13:57
Dominique Rondé Re: Lot of RocksDB files in tmp Directory Tue, 15 Nov, 14:00
Gyula Fóra Re: Proper way of adding external jars Tue, 15 Nov, 14:37
Vasiliki Kalavri Re: Too few memory segments provided. Hash Table needs at least 33 memory segments. Tue, 15 Nov, 14:38
Tomas Knap RDF/SPARQL and Flink Tue, 15 Nov, 14:47
Kostas Kloudas Re: Data Loss in HDFS after Job failure Tue, 15 Nov, 14:51
otherwise777 Re: Retrieving values from a dataset of datasets Tue, 15 Nov, 16:37
Aljoscha Krettek Re: Lot of RocksDB files in tmp Directory Tue, 15 Nov, 17:02
Kostas Kloudas Re: Data Loss in HDFS after Job failure Tue, 15 Nov, 17:52
Till Rohrmann Re: Proper way of adding external jars Tue, 15 Nov, 19:25
Cliff Resnick Re: Why are externalized checkpoints deleted on Job Manager exit? Tue, 15 Nov, 20:19
Philipp Bussche Subtask keeps on discovering new Kinesis shard when using Kinesalite Tue, 15 Nov, 20:51
Dominique Rondé AW: Re: Data Loss in HDFS after Job failure Tue, 15 Nov, 21:34
Kostas Kloudas Re: Data Loss in HDFS after Job failure Tue, 15 Nov, 21:40
Satish Chandra Gupta Re: Flink job restart at checkpoint interval Tue, 15 Nov, 21:52
Dromit Re: Why use Kafka after all? Wed, 16 Nov, 05:07
Tzu-Li (Gordon) Tai Re: Subtask keeps on discovering new Kinesis shard when using Kinesalite Wed, 16 Nov, 06:20
Tzu-Li (Gordon) Tai Re: Why use Kafka after all? Wed, 16 Nov, 07:23
criss Re: Kafka Stream to Database batch inserts Wed, 16 Nov, 09:09
criss Re: Error handling Wed, 16 Nov, 09:26
魏偉哲 Is incremental checkpointing already supported? Wed, 16 Nov, 11:05
otherwise777 33 segments problem with configuration set Wed, 16 Nov, 11:24
Kostas Kloudas Re: Is incremental checkpointing already supported? Wed, 16 Nov, 11:25
Gábor Gévay Re: Retrieving values from a dataset of datasets Wed, 16 Nov, 11:39
Till Rohrmann Re: Flink job restart at checkpoint interval Wed, 16 Nov, 13:16
Theodore Vasiloudis Additional steps needed for the Java quickstart guide Wed, 16 Nov, 13:49
Kostas Kloudas Re: Additional steps needed for the Java quickstart guide Wed, 16 Nov, 14:06
otherwise777 Re: 33 segments problem with configuration set Wed, 16 Nov, 14:10
otherwise777 Re: 33 segments problem with configuration set Wed, 16 Nov, 14:25
Vasiliki Kalavri Re: 33 segments problem with configuration set Wed, 16 Nov, 14:25
Gábor Hermann Any way to increase sort buffer size? Wed, 16 Nov, 16:29
Alberto Ramón Re: Why use Kafka after all? Wed, 16 Nov, 16:32
Philipp Bussche Re: Subtask keeps on discovering new Kinesis shard when using Kinesalite Wed, 16 Nov, 16:56
Philipp Bussche Re: Why use Kafka after all? Wed, 16 Nov, 17:01
Cliff Resnick Tame Flink UI? Wed, 16 Nov, 17:40
Ufuk Celebi Re: Tame Flink UI? Wed, 16 Nov, 18:15
Chesnay Schepler Re: Tame Flink UI? Wed, 16 Nov, 19:05
Niklas Semmler Re: A custom FileInputFormat Wed, 16 Nov, 19:13
Cliff Resnick Re: Tame Flink UI? Wed, 16 Nov, 19:38
Dominik Safaric Running the JobManager and TaskManager on the same node in a cluster Wed, 16 Nov, 20:49
CPC spark vs flink batch performance Wed, 16 Nov, 21:38
Satish Chandra Gupta Re: Flink job restart at checkpoint interval Thu, 17 Nov, 02:08
Eranga Heshan Enforce an operation to run in an exact host in flink Thu, 17 Nov, 06:26
Aljoscha Krettek Re: Error handling Thu, 17 Nov, 06:39
Tzu-Li (Gordon) Tai Re: Subtask keeps on discovering new Kinesis shard when using Kinesalite Thu, 17 Nov, 07:44
Eranga Heshan Re: Enforce an operation to run in an exact host in flink Thu, 17 Nov, 08:14
criss Re: Error handling Thu, 17 Nov, 08:36
Stephan Epping Docker Thu, 17 Nov, 10:19
Sendoh Could not find job with id XXXXX Thu, 17 Nov, 12:21
Sendoh Re: Could not find job with id XXXXX Thu, 17 Nov, 12:28
otherwise777 Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 12:31
Ufuk Celebi Re: Could not find job with id XXXXX Thu, 17 Nov, 12:36
Timo Walther Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 13:01
otherwise777 Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 13:03
otherwise777 Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 13:33
vinay patil Re: add FLINK_LIB_DIR to classpath on yarn -> add properties file to class path on yarn Thu, 17 Nov, 13:37
Vasiliki Kalavri Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 13:39
kaelumania Re: Maintaining watermarks per key, instead of per operator instance Thu, 17 Nov, 14:46
Timo Walther Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 17:42
otherwise777 Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 17:54
Ufuk Celebi Re: Could not find job with id XXXXX Thu, 17 Nov, 19:02
Aljoscha Krettek Re: Enforce an operation to run in an exact host in flink Thu, 17 Nov, 19:17
otherwise777 Re: Type of TypeVariable 'K' in 'class <> could not be determined Thu, 17 Nov, 19:24
daviD fileInpuFormat of type json Thu, 17 Nov, 19:59
Charlie Moad Cross product of datastream and dataset Thu, 17 Nov, 21:36
Maximilian Michels Re: add FLINK_LIB_DIR to classpath on yarn -> add properties file to class path on yarn Thu, 17 Nov, 22:53
Abdul Salam Shaikh Regarding time window based on the values received in the stream Fri, 18 Nov, 00:04
Dromit Re: Why use Kafka after all? Fri, 18 Nov, 00:12
Aparup Banerjee (apbanerj) FLINK-2821 - Flink on Kubernetes Fri, 18 Nov, 00:29
Eranga Heshan Re: Enforce an operation to run in an exact host in flink Fri, 18 Nov, 00:32
Matt Re: Why use Kafka after all? Fri, 18 Nov, 04:11
CPC Re: spark vs flink batch performance Fri, 18 Nov, 07:26
Fabian Hueske Re: fileInpuFormat of type json Fri, 18 Nov, 08:33
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Sep 2020383
Aug 2020723
Jul 2020840
Jun 2020653
May 2020766
Apr 2020849
Mar 2020795
Feb 2020690
Jan 2020652
Dec 2019530
Nov 2019527
Oct 2019542
Sep 2019534
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