flink-user mailing list archives: March 2019

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
zhijiang Re: Flink performance drops when async checkpoint is slow Fri, 01 Mar, 02:55
sen Re: Job Manager not able to fetch job info when restarted Fri, 01 Mar, 03:38
zhijiang Re: Checkpoints and catch-up burst (heavy back pressure) Fri, 01 Mar, 03:58
孙森 Re: submit job failed on Yarn HA Fri, 01 Mar, 06:26
Congxian Qiu Re: How do I compute the average and keep track of a state over a window in DataStream? Fri, 01 Mar, 07:16
Congxian Qiu Re: KeyBy distribution across taskslots Fri, 01 Mar, 07:23
Siew Wai Yow Flink Custom SourceFunction and SinkFunction Fri, 01 Mar, 08:39
Felipe Gutierrez Re: How do I compute the average and keep track of a state over a window in DataStream? Fri, 01 Mar, 08:48
Andy Hoang Kafka consumer do not commit offset at checkpoint Fri, 01 Mar, 09:00
LINZ, Arnaud RE: Checkpoints and catch-up burst (heavy back pressure) Fri, 01 Mar, 13:04
Ken Krugler Re: Checkpoints and catch-up burst (heavy back pressure) Fri, 01 Mar, 17:58
Steven Wu [1.7.1] job stuck in suspended state Fri, 01 Mar, 23:47
Seye Jin Flink 1.7.1 Inaccessible Sat, 02 Mar, 04:20
Padarn Wilson Re: Setting source vs sink vs window parallelism with data increase Sat, 02 Mar, 07:19
LINZ, Arnaud RE: Checkpoints and catch-up burst (heavy back pressure) Sat, 02 Mar, 08:45
anissa moussaoui StochasticOutlierSelection Sat, 02 Mar, 11:21
Le Xu Task slot sharing: force reallocation Sat, 02 Mar, 22:53
Mar_zieh Re: Automate Job submission with container Sun, 03 Mar, 11:15
Mar_zieh Re: Automate Job submission with container Sun, 03 Mar, 11:17
Mar_zieh Re: Automate Job submission with container Sun, 03 Mar, 11:43
Mar_zieh Command exited with status 1 in running Flink on marathon Sun, 03 Mar, 11:46
刘 文 [Flink-Question] In Flink parallel computing, how do different windows receive the data of their own partition, that is, how does Window determine which partition number the current Window belongs to? Sun, 03 Mar, 13:15
Gary Yao Re: submit job failed on Yarn HA Sun, 03 Mar, 19:03
Rong Rong Re: [Flink-Question] In Flink parallel computing, how do different windows receive the data of their own partition, that is, how does Window determine which partition number the current Window belongs to? Sun, 03 Mar, 20:19
zhijiang Re: Checkpoints and catch-up burst (heavy back pressure) Mon, 04 Mar, 03:21
刘 文 Re: [Flink-Question] In Flink parallel computing, how do different windows receive the data of their own partition, that is, how does Window determine which partition number the current Window belongs to? Mon, 04 Mar, 03:45
sam peng Hadoop 运行 mr 程序 报错 Mon, 04 Mar, 03:47
LINZ, Arnaud Re: Checkpoints and catch-up burst (heavy back pressure) Mon, 04 Mar, 06:56
杨光 flink sql about nested json Mon, 04 Mar, 07:38
孙森 event time timezone is not correct Mon, 04 Mar, 07:55
Fabian Hueske Re: Hadoop 运行 mr 程序 报错 Mon, 04 Mar, 08:15
sam peng Re: Hadoop 运行 mr 程序 报错 Mon, 04 Mar, 08:19
孙森 Re: submit job failed on Yarn HA Mon, 04 Mar, 09:01
Wouter Zorgdrager Using Flink in an university course Mon, 04 Mar, 10:32
Piotr Nowojski Re: Flink Custom SourceFunction and SinkFunction Mon, 04 Mar, 11:01
Piotr Nowojski Re: Setting source vs sink vs window parallelism with data increase Mon, 04 Mar, 11:16
Jörn Franke Re: Using Flink in an university course Mon, 04 Mar, 12:44
Averell S3 parquet sink - failed with S3 connection exception Mon, 04 Mar, 12:47
Piotr Nowojski Re: Task slot sharing: force reallocation Mon, 04 Mar, 12:49
Piotr Nowojski Re: Command exited with status 1 in running Flink on marathon Mon, 04 Mar, 13:10
Piotr Nowojski Re: [Flink-Question] In Flink parallel computing, how do different windows receive the data of their own partition, that is, how does Window determine which partition number the current Window belongs to? Mon, 04 Mar, 13:19
Fabian Hueske Re: Using Flink in an university course Mon, 04 Mar, 13:39
Till Rohrmann Re: [1.7.1] job stuck in suspended state Mon, 04 Mar, 13:55
Andrew Roberts Flink parallel subtask affinity of taskmanager Mon, 04 Mar, 14:00
Till Rohrmann Re: Flink 1.7.1 Inaccessible Mon, 04 Mar, 14:01
Wouter Zorgdrager Re: Using Flink in an university course Mon, 04 Mar, 14:16
Gary Yao Re: submit job failed on Yarn HA Mon, 04 Mar, 14:50
Gabriel Candal Task Manager high availability Mon, 04 Mar, 14:59
Piotr Nowojski Re: StochasticOutlierSelection Mon, 04 Mar, 15:08
Piotr Nowojski Re: event time timezone is not correct Mon, 04 Mar, 15:29
Ken Krugler Re: Checkpoints and catch-up burst (heavy back pressure) Mon, 04 Mar, 15:38
Piotr Nowojski Re: Flink parallel subtask affinity of taskmanager Mon, 04 Mar, 15:47
Timo Walther Re: flink sql about nested json Mon, 04 Mar, 16:13
Martin, Nick RE: EXT :Re: Flink 1.7.1 Inaccessible Mon, 04 Mar, 17:38
Flavio Pompermaier EventCountJob for Flink 1.7.2 Mon, 04 Mar, 17:54
Steven Wu Re: [1.7.1] job stuck in suspended state Mon, 04 Mar, 18:44
Addison Higham Re: Using Flink in an university course Mon, 04 Mar, 19:39
Le Xu Re: Task slot sharing: force reallocation Mon, 04 Mar, 20:08
Aggarwal, Ajay Checkpoint recovery and state external to flink Mon, 04 Mar, 20:08
min....@ubs.com Externalised checkpoint keeps ValueState after a crash of a Flink cluster Mon, 04 Mar, 20:16
Aggarwal, Ajay Broadcast state with WindowedStream Mon, 04 Mar, 21:36
Aggarwal, Ajay Re: Broadcast state with WindowedStream Mon, 04 Mar, 21:52
孙森 Re: event time timezone is not correct Tue, 05 Mar, 03:34
孙森 Re: submit job failed on Yarn HA Tue, 05 Mar, 06:40
Gary Yao Re: submit job failed on Yarn HA Tue, 05 Mar, 07:02
孙森 Re: submit job failed on Yarn HA Tue, 05 Mar, 07:08
Gary Yao Re: submit job failed on Yarn HA Tue, 05 Mar, 07:15
Congxian Qiu Re: Externalised checkpoint keeps ValueState after a crash of a Flink cluster Tue, 05 Mar, 07:20
杨光 Re: flink sql about nested json Tue, 05 Mar, 07:22
杨光 Re: flink sql about nested json Tue, 05 Mar, 07:25
Yun Tang Re: Checkpoint recovery and state external to flink Tue, 05 Mar, 09:04
Kostas Kloudas Re: S3 parquet sink - failed with S3 connection exception Tue, 05 Mar, 09:44
Flavio Pompermaier Re: EventCountJob for Flink 1.7.2 Tue, 05 Mar, 10:22
Piotr Nowojski Re: Task slot sharing: force reallocation Tue, 05 Mar, 11:00
Becket Qin [DISCUSS] Create a Flink ecosystem website Tue, 05 Mar, 11:03
Piotr Nowojski Re: event time timezone is not correct Tue, 05 Mar, 11:08
Piotr Nowojski Re: Command exited with status 1 in running Flink on marathon Tue, 05 Mar, 11:13
Averell Re: S3 parquet sink - failed with S3 connection exception Tue, 05 Mar, 11:18
Fabian Hueske Re: EventCountJob for Flink 1.7.2 Tue, 05 Mar, 12:10
Stephen Connolly Re: Checkpoints and catch-up burst (heavy back pressure) Tue, 05 Mar, 12:48
Stephen Connolly Re: Checkpoints and catch-up burst (heavy back pressure) Tue, 05 Mar, 12:55
Flavio Pompermaier Re: EventCountJob for Flink 1.7.2 Tue, 05 Mar, 13:48
Gabriel Candal RMQSource synchronous message ack Tue, 05 Mar, 14:07
josefernandes Apache Flink - Task Manager HA setup Tue, 05 Mar, 14:14
Till Rohrmann Re: Task slot sharing: force reallocation Tue, 05 Mar, 15:24
Aggarwal, Ajay Re: Checkpoint recovery and state external to flink Tue, 05 Mar, 17:26
Robert Metzger Re: [DISCUSS] Create a Flink ecosystem website Tue, 05 Mar, 17:36
Le Xu Re: Task slot sharing: force reallocation Tue, 05 Mar, 21:57
Bowen Li Re: [DISCUSS] Create a Flink ecosystem website Tue, 05 Mar, 22:23
vino yang Re: [DISCUSS] Create a Flink ecosystem website Wed, 06 Mar, 01:49
Shaoxuan Wang Re: [DISCUSS] Create a Flink ecosystem website Wed, 06 Mar, 02:40
Becket Qin Re: [DISCUSS] Create a Flink ecosystem website Wed, 06 Mar, 02:46
Becket Qin Re: [DISCUSS] Create a Flink ecosystem website Wed, 06 Mar, 02:49
孙森 Re: submit job failed on Yarn HA Wed, 06 Mar, 02:58
Seye Jin Re: EXT :Re: Flink 1.7.1 Inaccessible Wed, 06 Mar, 03:31
marzieh ghasemi Re: Command exited with status 1 in running Flink on marathon Wed, 06 Mar, 06:39
Gary Yao Re: submit job failed on Yarn HA Wed, 06 Mar, 07:19
孙森 Re: submit job failed on Yarn HA Wed, 06 Mar, 08:44
Pavel Potseluev Problems with restoring from savepoint Wed, 06 Mar, 09:06
Parth Sarathy How to check validity or completeness of created checkpoint/savepoint Wed, 06 Mar, 09:21
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
May 2019320
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