flink-user mailing list archives: March 2019

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Re: Flink performance drops when async checkpoint is slow
zhijiang   Re: Flink performance drops when async checkpoint is slow Fri, 01 Mar, 02:55
Stephan Ewen     Re: Flink performance drops when async checkpoint is slow Wed, 20 Mar, 09:09
Re: Job Manager not able to fetch job info when restarted
sen   Re: Job Manager not able to fetch job info when restarted Fri, 01 Mar, 03:38
Re: Checkpoints and catch-up burst (heavy back pressure)
zhijiang   Re: Checkpoints and catch-up burst (heavy back pressure) Fri, 01 Mar, 03:58
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
LINZ, Arnaud         Re: Checkpoints and catch-up burst (heavy back pressure) Mon, 04 Mar, 06:56
Ken Krugler           Re: Checkpoints and catch-up burst (heavy back pressure) Mon, 04 Mar, 15:38
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
LINZ, Arnaud           RE: Checkpoints and catch-up burst (heavy back pressure) Wed, 06 Mar, 11:09
LINZ, Arnaud     RE: Checkpoints and catch-up burst (heavy back pressure) Sat, 02 Mar, 08:45
zhijiang     Re: Checkpoints and catch-up burst (heavy back pressure) Mon, 04 Mar, 03:21
Re: submit job failed on Yarn HA
孙森   Re: submit job failed on Yarn HA Fri, 01 Mar, 06:26
Gary Yao     Re: submit job failed on Yarn HA Sun, 03 Mar, 19:03
孙森       Re: submit job failed on Yarn HA Mon, 04 Mar, 09:01
Gary Yao         Re: submit job failed on Yarn HA Mon, 04 Mar, 14:50
孙森           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
孙森                   Re: submit job failed on Yarn HA Wed, 06 Mar, 02:58
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
Re: How do I compute the average and keep track of a state over a window in DataStream?
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
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
Re: KeyBy distribution across taskslots
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
Piotr Nowojski   Re: Flink Custom SourceFunction and SinkFunction Mon, 04 Mar, 11:01
Andy Hoang Kafka consumer do not commit offset at checkpoint Fri, 01 Mar, 09:00
Steven Wu [1.7.1] job stuck in suspended state Fri, 01 Mar, 23:47
Till Rohrmann   Re: [1.7.1] job stuck in suspended state Mon, 04 Mar, 13:55
Steven Wu     Re: [1.7.1] job stuck in suspended state Mon, 04 Mar, 18:44
Till Rohrmann       Re: [1.7.1] job stuck in suspended state Wed, 06 Mar, 12:21
Till Rohrmann         Re: [1.7.1] job stuck in suspended state Wed, 06 Mar, 15:34
Seye Jin Flink 1.7.1 Inaccessible Sat, 02 Mar, 04:20
Till Rohrmann   Re: Flink 1.7.1 Inaccessible Mon, 04 Mar, 14:01
Martin, Nick     RE: EXT :Re: Flink 1.7.1 Inaccessible Mon, 04 Mar, 17:38
Seye Jin       Re: EXT :Re: Flink 1.7.1 Inaccessible Wed, 06 Mar, 03:31
Till Rohrmann         Re: EXT :Re: Flink 1.7.1 Inaccessible Wed, 06 Mar, 10:26
Seye Jin           Re: EXT :Re: Flink 1.7.1 Inaccessible Wed, 06 Mar, 10:43
Re: Setting source vs sink vs window parallelism with data increase
Padarn Wilson   Re: Setting source vs sink vs window parallelism with data increase Sat, 02 Mar, 07:19
Piotr Nowojski     Re: Setting source vs sink vs window parallelism with data increase Mon, 04 Mar, 11:16
Piotr Nowojski       Re: Setting source vs sink vs window parallelism with data increase Wed, 06 Mar, 10:02
Padarn Wilson         Re: Setting source vs sink vs window parallelism with data increase Wed, 06 Mar, 13:44
Padarn Wilson           Re: Setting source vs sink vs window parallelism with data increase Sat, 23 Mar, 11:49
Piotr Nowojski             Re: Setting source vs sink vs window parallelism with data increase Wed, 27 Mar, 09:02
anissa moussaoui StochasticOutlierSelection Sat, 02 Mar, 11:21
Piotr Nowojski   Re: StochasticOutlierSelection Mon, 04 Mar, 15:08
Piotr Nowojski     Re: StochasticOutlierSelection Thu, 21 Mar, 13:09
anissa moussaoui       Fwd: StochasticOutlierSelection Fri, 22 Mar, 14:20
Le Xu Task slot sharing: force reallocation Sat, 02 Mar, 22:53
Piotr Nowojski   Re: Task slot sharing: force reallocation Mon, 04 Mar, 12:49
Le Xu     Re: Task slot sharing: force reallocation Mon, 04 Mar, 20:08
Piotr Nowojski       Re: Task slot sharing: force reallocation Tue, 05 Mar, 11:00
Till Rohrmann         Re: Task slot sharing: force reallocation Tue, 05 Mar, 15:24
Le Xu           Re: Task slot sharing: force reallocation Tue, 05 Mar, 21:57
Till Rohrmann             Re: Task slot sharing: force reallocation Wed, 06 Mar, 10:23
Le Xu               Re: Task slot sharing: force reallocation Wed, 06 Mar, 19:13
Till Rohrmann                 Re: Task slot sharing: force reallocation Thu, 07 Mar, 09:36
Le Xu                   Re: Task slot sharing: force reallocation Wed, 13 Mar, 03:21
Till Rohrmann                     Re: Task slot sharing: force reallocation Tue, 19 Mar, 16:37
Re: Automate Job submission with container
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
Piotr Nowojski   Re: Command exited with status 1 in running Flink on marathon Mon, 04 Mar, 13:10
Piotr Nowojski     Re: Command exited with status 1 in running Flink on marathon Tue, 05 Mar, 11:13
marzieh ghasemi       Re: Command exited with status 1 in running Flink on marathon Wed, 06 Mar, 06:39
刘 文 [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
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
刘 文     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
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
sam peng Hadoop 运行 mr 程序 报错 Mon, 04 Mar, 03:47
Fabian Hueske   Re: Hadoop 运行 mr 程序 报错 Mon, 04 Mar, 08:15
sam peng   Re: Hadoop 运行 mr 程序 报错 Mon, 04 Mar, 08:19
杨光 flink sql about nested json Mon, 04 Mar, 07:38
Timo Walther   Re: flink sql about nested json Mon, 04 Mar, 16:13
杨光     Re: flink sql about nested json Tue, 05 Mar, 07:22
杨光     Re: flink sql about nested json Tue, 05 Mar, 07:25
孙森 event time timezone is not correct Mon, 04 Mar, 07:55
Piotr Nowojski   Re: event time timezone is not correct Mon, 04 Mar, 15:29
孙森     Re: event time timezone is not correct Tue, 05 Mar, 03:34
Piotr Nowojski       Re: event time timezone is not correct Tue, 05 Mar, 11:08
Wouter Zorgdrager Using Flink in an university course Mon, 04 Mar, 10:32
Jörn Franke   Re: Using Flink in an university course Mon, 04 Mar, 12:44
Fabian Hueske     Re: Using Flink in an university course Mon, 04 Mar, 13:39
Wouter Zorgdrager       Re: Using Flink in an university course Mon, 04 Mar, 14:16
Addison Higham         Re: Using Flink in an university course Mon, 04 Mar, 19:39
Wouter Zorgdrager           Re: Using Flink in an university course Wed, 06 Mar, 13:42
Averell S3 parquet sink - failed with S3 connection exception Mon, 04 Mar, 12:47
Kostas Kloudas   Re: S3 parquet sink - failed with S3 connection exception Tue, 05 Mar, 09:44
Averell     Re: S3 parquet sink - failed with S3 connection exception Tue, 05 Mar, 11:18
Averell     Re: S3 parquet sink - failed with S3 connection exception Sun, 10 Mar, 11:44
Averell       Re: S3 parquet sink - failed with S3 connection exception Fri, 15 Mar, 01:56
Andrew Roberts Flink parallel subtask affinity of taskmanager Mon, 04 Mar, 14:00
Piotr Nowojski   Re: Flink parallel subtask affinity of taskmanager Mon, 04 Mar, 15:47
Gabriel Candal Task Manager high availability Mon, 04 Mar, 14:59
Flavio Pompermaier EventCountJob for Flink 1.7.2 Mon, 04 Mar, 17:54
Flavio Pompermaier   Re: EventCountJob for Flink 1.7.2 Tue, 05 Mar, 10:22
Fabian Hueske     Re: EventCountJob for Flink 1.7.2 Tue, 05 Mar, 12:10
Flavio Pompermaier       Re: EventCountJob for Flink 1.7.2 Tue, 05 Mar, 13:48
Aggarwal, Ajay Checkpoint recovery and state external to flink Mon, 04 Mar, 20:08
Yun Tang   Re: Checkpoint recovery and state external to flink Tue, 05 Mar, 09:04
Aggarwal, Ajay     Re: Checkpoint recovery and state external to flink Tue, 05 Mar, 17:26
min....@ubs.com Externalised checkpoint keeps ValueState after a crash of a Flink cluster Mon, 04 Mar, 20:16
Congxian Qiu   Re: Externalised checkpoint keeps ValueState after a crash of a Flink cluster Tue, 05 Mar, 07:20
Aggarwal, Ajay Broadcast state with WindowedStream Mon, 04 Mar, 21:36
Aggarwal, Ajay   Re: Broadcast state with WindowedStream Mon, 04 Mar, 21:52
Aggarwal, Ajay     Re: Broadcast state with WindowedStream Wed, 06 Mar, 14:49
Becket Qin [DISCUSS] Create a Flink ecosystem website Tue, 05 Mar, 11:03
Robert Metzger   Re: [DISCUSS] Create a Flink ecosystem website Tue, 05 Mar, 17:36
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
Robert Metzger           Re: [DISCUSS] Create a Flink ecosystem website Wed, 06 Mar, 13:30
Ufuk Celebi             Re: [DISCUSS] Create a Flink ecosystem website Wed, 06 Mar, 20:59
Becket Qin               Re: [DISCUSS] Create a Flink ecosystem website Thu, 07 Mar, 09:05
Robert Metzger                 Re: [DISCUSS] Create a Flink ecosystem website Thu, 07 Mar, 12:46
Becket Qin                   Re: [DISCUSS] Create a Flink ecosystem website Thu, 07 Mar, 14:06
Bowen Li                     Re: [DISCUSS] Create a Flink ecosystem website Fri, 08 Mar, 22:32
Niels Basjes                       Re: [DISCUSS] Create a Flink ecosystem website Mon, 11 Mar, 10:37
Robert Metzger                         Re: [DISCUSS] Create a Flink ecosystem website Wed, 13 Mar, 17:34
Becket Qin                           Re: [DISCUSS] Create a Flink ecosystem website Thu, 14 Mar, 13:45
Robert Metzger                             Re: [DISCUSS] Create a Flink ecosystem website Fri, 15 Mar, 09:39
Becket Qin                               Re: [DISCUSS] Create a Flink ecosystem website Sat, 16 Mar, 14:47
Robert Metzger                                 Re: [DISCUSS] Create a Flink ecosystem website Mon, 18 Mar, 13:08
Becket Qin                                   Re: [DISCUSS] Create a Flink ecosystem website Tue, 19 Mar, 01:41
Robert Metzger                                     Re: [DISCUSS] Create a Flink ecosystem website Tue, 19 Mar, 10:07
Becket Qin                                       Re: [DISCUSS] Create a Flink ecosystem website Wed, 20 Mar, 03:10
Robert Metzger                                         Re: [DISCUSS] Create a Flink ecosystem website Thu, 21 Mar, 09:08
Robert Metzger                                           Re: [DISCUSS] Create a Flink ecosystem website Thu, 21 Mar, 14:07
Becket Qin                                             Re: [DISCUSS] Create a Flink ecosystem website Thu, 21 Mar, 18:14
Oytun Tez                                               Re: [DISCUSS] Create a Flink ecosystem website Thu, 21 Mar, 18:18
Gabriel Candal RMQSource synchronous message ack Tue, 05 Mar, 14:07
Chesnay Schepler   Re: RMQSource synchronous message ack Wed, 06 Mar, 12:11
gcandal     Re: RMQSource synchronous message ack Mon, 11 Mar, 10:17
josefernandes Apache Flink - Task Manager HA setup Tue, 05 Mar, 14:14
Pavel Potseluev Problems with restoring from savepoint Wed, 06 Mar, 09:06
Tzu-Li (Gordon) Tai   Re: Problems with restoring from savepoint Wed, 06 Mar, 13:43
Павел Поцелуев     Re: Problems with restoring from savepoint Wed, 06 Mar, 15:10
Parth Sarathy How to check validity or completeness of created checkpoint/savepoint Wed, 06 Mar, 09:21
Chesnay Schepler   Re: How to check validity or completeness of created checkpoint/savepoint Wed, 06 Mar, 12:30
Re: Starting Flink cluster and running a job
Konstantin Knauf   Re: Starting Flink cluster and running a job Wed, 06 Mar, 10:27
Boris Lublinsky     Re: Starting Flink cluster and running a job Wed, 06 Mar, 14:16
Konstantin Knauf       Re: Starting Flink cluster and running a job Wed, 06 Mar, 14:23
Re: Data loss when restoring from savepoint
Konstantin Knauf   Re: Data loss when restoring from savepoint Wed, 06 Mar, 11:17
Juho Autio     Re: Data loss when restoring from savepoint Wed, 06 Mar, 11:41
Juho Autio       Re: Data loss when restoring from savepoint Thu, 07 Mar, 14:01
Konstantin Knauf         Re: Data loss when restoring from savepoint Thu, 07 Mar, 15:33
Juho Autio           Re: Data loss when restoring from savepoint Thu, 07 Mar, 17:41
Konstantin Knauf             Re: Data loss when restoring from savepoint Tue, 12 Mar, 15:29
Gyula Fóra               Re: Data loss when restoring from savepoint Tue, 12 Mar, 15:40
Juho Autio                 Re: Data loss when restoring from savepoint Thu, 14 Mar, 11:20
Konstantin Knauf                   Re: Data loss when restoring from savepoint Mon, 18 Mar, 16:26
Juho Autio                     Re: Data loss when restoring from savepoint Tue, 19 Mar, 13:05
Juho Autio                       Re: Data loss when restoring from savepoint Tue, 26 Mar, 10:00
Konstantin Knauf                         Re: Data loss when restoring from savepoint Tue, 26 Mar, 19:55
Juho Autio                           Re: Data loss when restoring from savepoint Thu, 28 Mar, 16:00
Konstantin Knauf                             Re: Data loss when restoring from savepoint Thu, 28 Mar, 17:08
Juho Autio                               Re: Data loss when restoring from savepoint Fri, 29 Mar, 13:21
Laura Uzcátegui Job continuously failing after Checkpoint Restore Wed, 06 Mar, 13:35
Yun Tang   Re: Job continuously failing after Checkpoint Restore Wed, 06 Mar, 17:14
Rich Bowen 4 Apache Events in 2019: DC Roadshow soon; next up Chicago, Las Vegas, and Berlin! Wed, 06 Mar, 14:00
刘 文 DataStream EventTime last data cannot be output? Wed, 06 Mar, 14:51
Stephen Connolly   Re: DataStream EventTime last data cannot be output? Thu, 07 Mar, 11:28
Aggarwal, Ajay Joining two streams of different priorities Wed, 06 Mar, 15:16
Fabian Hueske   Re: Joining two streams of different priorities Mon, 11 Mar, 08:10
Jack Tuck How to monitor Apache Flink in AWS EMR (ElasticMapReduce)? Wed, 06 Mar, 19:39
Jack Tuck   How to monitor Apache Flink in AWS EMR (ElasticMapReduce)? Wed, 06 Mar, 19:48
Yun Tang   Re: How to monitor Apache Flink in AWS EMR (ElasticMapReduce)? Thu, 07 Mar, 03:24
shkob1 Schema Evolution on Dynamic Schema Wed, 06 Mar, 20:52
Rong Rong   Re: Schema Evolution on Dynamic Schema Thu, 07 Mar, 18:40
Shahar Cizer Kobrinsky     Re: Schema Evolution on Dynamic Schema Thu, 07 Mar, 19:20
Rong Rong       Re: Schema Evolution on Dynamic Schema Fri, 08 Mar, 15:53
shkob1         Re: Schema Evolution on Dynamic Schema Fri, 08 Mar, 20:07
Rong Rong           Re: Schema Evolution on Dynamic Schema Sun, 10 Mar, 00:41
Shahar Cizer Kobrinsky             Re: Schema Evolution on Dynamic Schema Mon, 18 Mar, 18:44
Shahar Cizer Kobrinsky               Re: Schema Evolution on Dynamic Schema Mon, 18 Mar, 19:02
Fabian Hueske                 Re: Schema Evolution on Dynamic Schema Tue, 19 Mar, 09:02
Shahar Cizer Kobrinsky                   Re: Schema Evolution on Dynamic Schema Tue, 19 Mar, 18:50
Shahar Cizer Kobrinsky                     Re: Schema Evolution on Dynamic Schema Tue, 19 Mar, 21:27
Fabian Hueske                       Re: Schema Evolution on Dynamic Schema Wed, 20 Mar, 08:59
shkob1                         Re: Schema Evolution on Dynamic Schema Tue, 26 Mar, 19:54
shkob1                           Re: Schema Evolution on Dynamic Schema Tue, 26 Mar, 20:53
shkob1                             Re: Schema Evolution on Dynamic Schema Tue, 26 Mar, 22:09
Shahar Cizer Kobrinsky                         Re: Schema Evolution on Dynamic Schema Thu, 28 Mar, 21:28
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
May 2019372
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