flink-user mailing list archives: February 2018

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Gregory Fee Triggering a Savepoint Thu, 25 Jan, 19:52
Fabian Hueske   Re: Triggering a Savepoint Wed, 07 Feb, 09:31
Raja.Aravapalli Flink on YARN || Monitoring REST API Not Working || Please help Thu, 01 Feb, 02:36
Jins George   Re: Flink on YARN || Monitoring REST API Not Working || Please help Thu, 01 Feb, 02:51
Raja.Aravapalli     Re: [EXTERNAL] Re: Flink on YARN || Monitoring REST API Not Working || Please help Thu, 01 Feb, 03:24
Austin York How to enable “upsert mode” for dynamic tables? Thu, 01 Feb, 04:25
Puneet Kinra   Re: How to enable “upsert mode” for dynamic tables? Thu, 01 Feb, 05:08
Fabian Hueske     Re: How to enable “upsert mode” for dynamic tables? Thu, 01 Feb, 09:16
Austin York       Re: How to enable “upsert mode” for dynamic tables? Fri, 02 Feb, 22:33
Mu Kong JobManager doesn't recover in HA mode Thu, 01 Feb, 06:11
Tony Wei   Re: JobManager doesn't recover in HA mode Thu, 01 Feb, 06:50
Mu Kong     Re: JobManager doesn't recover in HA mode Thu, 01 Feb, 07:00
Mu Kong       Re: JobManager doesn't recover in HA mode Thu, 01 Feb, 07:04
Maciek Próchniak queryable state API Thu, 01 Feb, 08:19
Fabian Hueske   Re: queryable state API Mon, 05 Feb, 09:03
RE: S3 for state backend in Flink 1.4.0
Marchant, Hayden   RE: S3 for state backend in Flink 1.4.0 Thu, 01 Feb, 08:21
Edward Rojas     RE: S3 for state backend in Flink 1.4.0 Thu, 01 Feb, 16:08
Marchant, Hayden       RE: S3 for state backend in Flink 1.4.0 Wed, 07 Feb, 14:56
Re: Maintain heavy hitters in Flink application
m@xi   Re: Maintain heavy hitters in Flink application Thu, 01 Feb, 08:31
Timo Walther     Re: Maintain heavy hitters in Flink application Thu, 01 Feb, 10:01
m@xi       Re: Maintain heavy hitters in Flink application Sat, 03 Feb, 06:24
Re: Managed operator state treating state of all parallel operators as the same
m@xi   Re: Managed operator state treating state of all parallel operators as the same Thu, 01 Feb, 08:45
Marchant, Hayden Reading bounded data from Kafka in Flink job Thu, 01 Feb, 10:42
Fabian Hueske   Re: Reading bounded data from Kafka in Flink job Mon, 05 Feb, 09:10
Re: How does BucketingSink generate a SUCCESS file when a directory is finished
Kien Truong   Re: How does BucketingSink generate a SUCCESS file when a directory is finished Thu, 01 Feb, 12:06
xiaobin yan     Re: How does BucketingSink generate a SUCCESS file when a directory is finished Mon, 05 Feb, 05:43
Fabian Hueske       Re: How does BucketingSink generate a SUCCESS file when a directory is finished Mon, 05 Feb, 10:34
xiaobin yan         Re: How does BucketingSink generate a SUCCESS file when a directory is finished Tue, 06 Feb, 03:14
Fabian Hueske           Re: How does BucketingSink generate a SUCCESS file when a directory is finished Tue, 06 Feb, 09:35
xiaobin yan             Re: How does BucketingSink generate a SUCCESS file when a directory is finished Tue, 06 Feb, 09:50
xiaobin yan               Re: How does BucketingSink generate a SUCCESS file when a directory is finished Tue, 06 Feb, 10:03
Fabian Hueske                 Re: How does BucketingSink generate a SUCCESS file when a directory is finished Tue, 06 Feb, 13:16
RE: Multiple Elasticsearch sinks not working in Flink
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
Fabian Hueske       Re: Multiple Elasticsearch sinks not working in Flink Mon, 05 Feb, 09:42
Marchant, Hayden Latest version of Kafka Thu, 01 Feb, 13:46
Piotr Nowojski   Re: Latest version of Kafka Fri, 02 Feb, 14:36
Marchant, Hayden     RE: Latest version of Kafka Wed, 07 Feb, 14:51
LINZ, Arnaud How to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job ? Thu, 01 Feb, 15:23
LINZ, Arnaud   RE: How to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job ? Wed, 07 Feb, 09:48
Chesnay Schepler     Re: How to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job ? Wed, 07 Feb, 13:52
Julio Biason Extending Flink Slots when running on Yarn Thu, 01 Feb, 16:09
Gary Yao   Re: Extending Flink Slots when running on Yarn Fri, 02 Feb, 11:32
Vinay Patil Get the JobID when Flink job fails Thu, 01 Feb, 19:50
Vinay Patil   Re: Get the JobID when Flink job fails Tue, 06 Feb, 17:14
Chesnay Schepler     Re: Get the JobID when Flink job fails Wed, 07 Feb, 07:55
Chesnay Schepler   Re: Get the JobID when Flink job fails Wed, 07 Feb, 07:43
Re: Flink on K8s job submission best practices
Christophe Jolif   Re: Flink on K8s job submission best practices Thu, 01 Feb, 20:22
Ishwara Varnasi Flink on AWS EMR - how to use flink-log4j configuration? Thu, 01 Feb, 20:27
Raja.Aravapalli Flink REST API Thu, 01 Feb, 20:29
Gary Yao   Re: Flink REST API Fri, 02 Feb, 16:20
Raja.Aravapalli     Re: [EXTERNAL] Re: Flink REST API Fri, 09 Feb, 14:54
Gary Yao       Re: [EXTERNAL] Re: Flink REST API Fri, 09 Feb, 15:25
Raja.Aravapalli         Re: [EXTERNAL] Re: Flink REST API Fri, 09 Feb, 15:46
Gary Yao           Re: [EXTERNAL] Re: Flink REST API Mon, 12 Feb, 06:36
Vishal Santoshi CEP issue Thu, 01 Feb, 21:53
Vishal Santoshi   Re: CEP issue Thu, 01 Feb, 22:09
Vishal Santoshi     Re: CEP issue Thu, 01 Feb, 22:17
Vishal Santoshi       Re: CEP issue Thu, 01 Feb, 22:33
Vishal Santoshi         Re: CEP issue Thu, 01 Feb, 22:34
Dawid Wysakowicz           Re: CEP issue Fri, 02 Feb, 12:53
Vishal Santoshi             Re: CEP issue Fri, 02 Feb, 15:05
Kostas Kloudas               Re: CEP issue Tue, 06 Feb, 17:00
Vishal Santoshi                 Re: CEP issue Mon, 26 Feb, 19:09
Jürgen Thomann Getting Key from keyBy() in ProcessFunction Fri, 02 Feb, 14:24
Ken Krugler   Re: Getting Key from keyBy() in ProcessFunction Fri, 02 Feb, 17:37
Jürgen Thomann     Re: Getting Key from keyBy() in ProcessFunction Sun, 04 Feb, 14:14
Ken Krugler       Re: Getting Key from keyBy() in ProcessFunction Sun, 04 Feb, 19:36
Piotr Nowojski         Re: Getting Key from keyBy() in ProcessFunction Mon, 05 Feb, 08:56
RocksDB / checkpoint questions
Christophe Jolif   RocksDB / checkpoint questions Fri, 02 Feb, 16:30
Kien Truong   Re: RocksDB / checkpoint questions Sat, 03 Feb, 06:25
Christophe Jolif     Re: RocksDB / checkpoint questions Sat, 03 Feb, 16:45
Stefan Richter       Re: RocksDB / checkpoint questions Mon, 05 Feb, 10:31
Christophe Jolif         Re: RocksDB / checkpoint questions Mon, 05 Feb, 10:53
geoff halmo Flink not writing last few elements to disk Fri, 02 Feb, 17:32
Piotr Nowojski   Re: Flink not writing last few elements to disk Mon, 05 Feb, 08:18
Kien Truong Reduce parallelism without network transfer. Sat, 03 Feb, 03:39
Piotr Nowojski   Re: Reduce parallelism without network transfer. Mon, 05 Feb, 08:28
Kien Truong     Re: Reduce parallelism without network transfer. Tue, 06 Feb, 03:32
Piotr Nowojski       Re: Reduce parallelism without network transfer. Tue, 06 Feb, 08:05
Christophe Jolif Kafka and parallelism Sat, 03 Feb, 17:53
Tzu-Li (Gordon) Tai   Re: Kafka and parallelism Mon, 05 Feb, 08:52
Christophe Jolif     Re: Kafka and parallelism Mon, 05 Feb, 10:42
Tzu-Li (Gordon) Tai       Re: Kafka and parallelism Mon, 05 Feb, 16:51
Christophe Jolif     Re: Kafka and parallelism Wed, 07 Feb, 08:40
Tzu-Li (Gordon) Tai       Re: Kafka and parallelism Wed, 07 Feb, 09:27
Christophe Jolif         Re: Kafka and parallelism Wed, 07 Feb, 11:27
miki haiat Global window keyBy Sun, 04 Feb, 14:39
Piotr Nowojski   Re: Global window keyBy Mon, 05 Feb, 08:40
miki haiat     Fwd: Global window keyBy Mon, 05 Feb, 11:36
syed Checkpoint is not triggering as per configuration Mon, 05 Feb, 02:19
Piotr Nowojski   Re: Checkpoint is not triggering as per configuration Mon, 05 Feb, 09:33
mingleizhang Why does jobmanager running needs slot ? Mon, 05 Feb, 07:38
Piotr Nowojski   Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:30
mingleizhang     Re:Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:44
Piotr Nowojski       Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:49
mingleizhang         Re:Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:51
Piotr Nowojski           Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 09:56
mingleizhang             Re:Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 10:01
Piotr Nowojski               Re: Why does jobmanager running needs slot ? Mon, 05 Feb, 10:03
Re: Spurious warning in logs about flink-queryable-state-runtime
Fabian Hueske   Re: Spurious warning in logs about flink-queryable-state-runtime Mon, 05 Feb, 09:18
Chesnay Schepler     Re: Spurious warning in logs about flink-queryable-state-runtime Wed, 07 Feb, 09:24
Re: Task Manager detached under load
Till Rohrmann   Re: Task Manager detached under load Mon, 05 Feb, 10:55
Ashish Pokharel     Re: Task Manager detached under load Tue, 06 Feb, 01:26
ashish pok     Re: Task Manager detached under load Sat, 24 Feb, 15:02
johannes.barn...@clarivate.com Rebalance to subtasks in same TaskManager instance Mon, 05 Feb, 14:16
Piotr Nowojski   Re: Rebalance to subtasks in same TaskManager instance Tue, 06 Feb, 08:27
johannes.barn...@clarivate.com     Re: Rebalance to subtasks in same TaskManager instance Wed, 07 Feb, 11:53
Christophe Jolif ML and Stream Mon, 05 Feb, 15:43
Fabian Hueske   Re: ML and Stream Mon, 05 Feb, 17:01
Christophe Jolif     Re: ML and Stream Mon, 05 Feb, 17:28
Fabian Hueske       Re: ML and Stream Mon, 05 Feb, 20:04
xiatao123 how to match external checkpoints with jobs during recovery Mon, 05 Feb, 19:27
Aljoscha Krettek   Re: how to match external checkpoints with jobs during recovery Tue, 06 Feb, 16:18
Re: Joining data in Streaming
Steven Wu   Re: Joining data in Streaming Tue, 06 Feb, 01:46
Marchant, Hayden     RE: Joining data in Streaming Wed, 07 Feb, 14:45
Tony Wei Will that be a problem if POJO key type didn't override equals? Tue, 06 Feb, 03:16
Timo Walther   Re: Will that be a problem if POJO key type didn't override equals? Tue, 06 Feb, 07:24
Tony Wei     Re: Will that be a problem if POJO key type didn't override equals? Tue, 06 Feb, 07:54
Timo Walther       Re: Will that be a problem if POJO key type didn't override equals? Tue, 06 Feb, 09:25
Tony Wei         Re: Will that be a problem if POJO key type didn't override equals? Tue, 06 Feb, 09:33
Data Engineer Testing flink class loading Tue, 06 Feb, 06:55
Aljoscha Krettek   Re: Testing flink class loading Tue, 06 Feb, 16:08
Henri Heiskanen deduplication with streaming sql Tue, 06 Feb, 10:11
Timo Walther   Re: deduplication with streaming sql Tue, 06 Feb, 12:36
Timo Walther     Re: deduplication with streaming sql Tue, 06 Feb, 12:59
Fabian Hueske       Re: deduplication with streaming sql Tue, 06 Feb, 13:45
Henri Heiskanen         Re: deduplication with streaming sql Tue, 06 Feb, 14:47
Fabian Hueske           Re: deduplication with streaming sql Tue, 06 Feb, 15:01
Henri Heiskanen             Re: deduplication with streaming sql Tue, 06 Feb, 15:09
Sofer, Tovi kafka as recovery only source Tue, 06 Feb, 14:31
Fabian Hueske   Re: kafka as recovery only source Wed, 07 Feb, 09:46
Sofer, Tovi     RE: kafka as recovery only source Wed, 07 Feb, 13:30
Re: Flink CEP exception during RocksDB update
Kostas Kloudas   Re: Flink CEP exception during RocksDB update Tue, 06 Feb, 17:03
Fwd: Question about flink checkpoint
Chengzhi Zhao   Fwd: Question about flink checkpoint Tue, 06 Feb, 18:15
Fabian Hueske     Re: Question about flink checkpoint Wed, 07 Feb, 09:17
Chengzhi Zhao       Re: Question about flink checkpoint Wed, 07 Feb, 22:52
Fabian Hueske         Re: Question about flink checkpoint Thu, 08 Feb, 08:28
Edward Classloader leak with Kafka Mbeans / JMX Reporter Tue, 06 Feb, 20:30
Chesnay Schepler   Re: Classloader leak with Kafka Mbeans / JMX Reporter Wed, 07 Feb, 07:58
Chesnay Schepler     Re: Classloader leak with Kafka Mbeans / JMX Reporter Wed, 07 Feb, 07:59
Edward       Re: Classloader leak with Kafka Mbeans / JMX Reporter Wed, 07 Feb, 12:37
Chesnay Schepler         Re: Classloader leak with Kafka Mbeans / JMX Reporter Wed, 07 Feb, 13:26
Edward           Re: Classloader leak with Kafka Mbeans / JMX Reporter Fri, 09 Feb, 13:19
Chesnay Schepler             Re: Classloader leak with Kafka Mbeans / JMX Reporter Tue, 13 Feb, 08:40
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
Sep 2019233
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