flink-user mailing list archives: June 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Re: Trigerring Savepoint for the Flink Job
Anil   Re: Trigerring Savepoint for the Flink Job Fri, 01 Jun, 03:38
Rong Rong     Re: Trigerring Savepoint for the Flink Job Fri, 01 Jun, 18:36
Anil       Re: Trigerring Savepoint for the Flink Job Mon, 04 Jun, 18:08
Anil         Re: Trigerring Savepoint for the Flink Job Mon, 04 Jun, 18:12
Rong Rong           Re: Trigerring Savepoint for the Flink Job Mon, 04 Jun, 20:45
Xinyu Zhang How to set UserGroupInformation? Fri, 01 Jun, 04:31
Till Rohrmann   Re: How to set UserGroupInformation? Fri, 01 Jun, 14:25
Rong Rong     Re: How to set UserGroupInformation? Fri, 01 Jun, 18:20
Xinyu Zhang       How to set UserGroupInformation? Mon, 04 Jun, 08:36
RE: Looking for a working POM file example for EMR cluster
Georgi Stoyanov   RE: Looking for a working POM file example for EMR cluster Fri, 01 Jun, 06:18
Sandybayev, Turar (CAI - Atlanta)     Re: Looking for a working POM file example for EMR cluster Fri, 01 Jun, 20:25
Re: Flink and AWS S3 integration: java.lang.NullPointerException: null uri host
Fabian Wollert   Re: Flink and AWS S3 integration: java.lang.NullPointerException: null uri host Fri, 01 Jun, 06:20
Re: Is Flink:1.5 Docker image broken?
Cameron Wood   Re: Is Flink:1.5 Docker image broken? Fri, 01 Jun, 07:10
Re: is it OK to PR just for code comment errors?
makeyang   Re: is it OK to PR just for code comment errors? Fri, 01 Jun, 07:13
Re: TimerService/Watermarks and Checkpoints
Fabian Hueske   Re: TimerService/Watermarks and Checkpoints Fri, 01 Jun, 07:22
Narayanan Arunachalam     Re: TimerService/Watermarks and Checkpoints Fri, 01 Jun, 19:43
Re: Multiple Task Slots support in Flink 1.5
Fabian Hueske   Re: Multiple Task Slots support in Flink 1.5 Fri, 01 Jun, 07:54
Abdul Qadeer     Re: Multiple Task Slots support in Flink 1.5 Fri, 01 Jun, 08:10
Till Rohrmann       Re: Multiple Task Slots support in Flink 1.5 Fri, 01 Jun, 13:21
Abdul Qadeer         Re: Multiple Task Slots support in Flink 1.5 Fri, 01 Jun, 19:52
Till Rohrmann           Re: Multiple Task Slots support in Flink 1.5 Fri, 01 Jun, 20:15
Re: S3 for state backend in Flink 1.4.0
Stephan Ewen   Re: S3 for state backend in Flink 1.4.0 Fri, 01 Jun, 14:40
Anil Submit Flink Job on Yarn cluster to restores its state from it's last savepoint Fri, 01 Jun, 14:43
Till Rohrmann   Re: Submit Flink Job on Yarn cluster to restores its state from it's last savepoint Fri, 01 Jun, 15:44
Re: Flink 1.2.1 - Job initial start time
Till Rohrmann   Re: Flink 1.2.1 - Job initial start time Fri, 01 Jun, 15:09
Till Rohrmann     Re: Flink 1.2.1 - Job initial start time Mon, 04 Jun, 07:26
Re: File does not exist prevent from Job manager to start .
Till Rohrmann   Re: File does not exist prevent from Job manager to start . Fri, 01 Jun, 15:18
miki haiat     Re: File does not exist prevent from Job manager to start . Sun, 03 Jun, 11:10
Till Rohrmann       Re: File does not exist prevent from Job manager to start . Mon, 04 Jun, 07:32
miki haiat         Re: File does not exist prevent from Job manager to start . Mon, 04 Jun, 10:31
Till Rohrmann           Re: File does not exist prevent from Job manager to start . Mon, 04 Jun, 13:27
miki haiat             Re: File does not exist prevent from Job manager to start . Wed, 06 Jun, 11:05
Till Rohrmann               Re: File does not exist prevent from Job manager to start . Mon, 11 Jun, 08:41
Re: some default config questions
Till Rohrmann   Re: some default config questions Fri, 01 Jun, 15:42
makeyang     Re: some default config questions Tue, 05 Jun, 02:09
Radhya Sahal Ask for SQL using kafka in Flink Fri, 01 Jun, 16:09
Rong Rong   Re: Ask for SQL using kafka in Flink Fri, 01 Jun, 22:31
Radhya Sahal     Re: Ask for SQL using kafka in Flink Sat, 02 Jun, 16:29
Radhya Sahal     Re: Ask for SQL using kafka in Flink Sat, 02 Jun, 16:30
Radhya Sahal     Re: Ask for SQL using kafka in Flink Sat, 02 Jun, 16:31
Timo Walther       Re: Ask for SQL using kafka in Flink Mon, 04 Jun, 07:57
Shuyi Chen         Re: Ask for SQL using kafka in Flink Mon, 04 Jun, 18:29
Rad Rad           Re: Ask for SQL using kafka in Flink Mon, 04 Jun, 19:19
Will Du           Re: Ask for SQL using kafka in Flink Mon, 04 Jun, 21:06
Timo Walther             Re: Ask for SQL using kafka in Flink Tue, 05 Jun, 07:24
Rad Rad         Re: Ask for SQL using kafka in Flink Mon, 04 Jun, 19:12
Fabian Hueske [ANNOUNCE] Flink Forward Berlin 2018 - Call for Presentations extended until June 11 Fri, 01 Jun, 16:41
Hao Sun Flink 1.5, failed to instantiate S3 FS Sat, 02 Jun, 00:12
Amit Jain   Re: Flink 1.5, failed to instantiate S3 FS Sat, 02 Jun, 08:05
Hao Sun     Re: Flink 1.5, failed to instantiate S3 FS Sat, 02 Jun, 23:40
Garvit Sharma ConcurrentModificationException while accessing managed keyed state Sat, 02 Jun, 04:08
sihua zhou   Re: ConcurrentModificationException while accessing managed keyed state Sat, 02 Jun, 04:51
aitozi   Re: ConcurrentModificationException while accessing managed keyed state Sat, 02 Jun, 13:19
Garvit Sharma     Re: ConcurrentModificationException while accessing managed keyed state Sat, 02 Jun, 14:40
aitozi       Re: ConcurrentModificationException while accessing managed keyed state Sat, 02 Jun, 14:46
sihua zhou       Re: ConcurrentModificationException while accessing managed keyed state Sat, 02 Jun, 15:02
Hao Sun Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Sat, 02 Jun, 05:34
Aljoscha Krettek   Re: Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Tue, 05 Jun, 16:09
Hao Sun     Re: Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Tue, 05 Jun, 16:23
Aljoscha Krettek       Re: Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Tue, 05 Jun, 16:38
Hao Sun         Re: Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Tue, 05 Jun, 18:33
Hao Sun           Re: Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Tue, 05 Jun, 18:43
Hao Sun             Re: Do I still need hadoop-aws libs when using Flink 1.5 and Presto? Tue, 05 Jun, 19:34
Rad Rad Java Code for Kafka Flink SQL Sat, 02 Jun, 17:26
Timo Walther   Re: Java Code for Kafka Flink SQL Mon, 04 Jun, 07:48
Vijay Balakrishnan Using Flink RocksDBStateBackend with EFS as an NFS mount for large image data Sat, 02 Jun, 23:09
Oleh Lukyrych Buffer congestion in a downstream operator hangs SourceContext.collect in an (in?)finite loop Sun, 03 Jun, 18:41
Connie Yang How to anchor a job level singleton object as part of TaskManager JVM? Sun, 03 Jun, 22:44
Connie Yang   Re: How to anchor a job level singleton object as part of TaskManager JVM? Sun, 03 Jun, 23:32
makeyang is there a config to ask taskmanager to keep retrying connect to jobmanager after Disassociated? Mon, 04 Jun, 06:24
makeyang   Re: is there a config to ask taskmanager to keep retrying connect to jobmanager after Disassociated? Mon, 04 Jun, 09:41
makeyang     Re: is there a config to ask taskmanager to keep retrying connect to jobmanager after Disassociated? Mon, 04 Jun, 09:42
makeyang       Re: is there a config to ask taskmanager to keep retrying connect to jobmanager after Disassociated? Tue, 05 Jun, 10:31
Chesnay Schepler         Re: is there a config to ask taskmanager to keep retrying connect to jobmanager after Disassociated? Tue, 05 Jun, 10:45
Till Rohrmann [ANNOUNCE] Weekly community update #23 Mon, 04 Jun, 08:26
Re: JVM metrics disappearing after job crash, restart
Fabian Hueske   Re: JVM metrics disappearing after job crash, restart Mon, 04 Jun, 08:44
Chesnay Schepler     Re: JVM metrics disappearing after job crash, restart Mon, 04 Jun, 08:56
Nikolas Davis       Re: JVM metrics disappearing after job crash, restart Tue, 05 Jun, 00:02
Chesnay Schepler         Re: JVM metrics disappearing after job crash, restart Tue, 05 Jun, 06:25
Stephan Ewen [DISCUSS] Flink 1.6 features Mon, 04 Jun, 09:21
Chesnay Schepler   Re: [DISCUSS] Flink 1.6 features Mon, 04 Jun, 09:29
sihua zhou   Re:[DISCUSS] Flink 1.6 features Mon, 04 Jun, 09:38
Antoine Philippot   Re: [DISCUSS] Flink 1.6 features Mon, 04 Jun, 09:50
Till Rohrmann     Re: [DISCUSS] Flink 1.6 features Mon, 04 Jun, 11:43
Che Lui Shum   Re: [DISCUSS] Flink 1.6 features Mon, 04 Jun, 21:29
Ben Yan     Re: [DISCUSS] Flink 1.6 features Tue, 05 Jun, 06:01
Hao Sun       Re: [DISCUSS] Flink 1.6 features Tue, 05 Jun, 22:01
Rico Bergmann         Re: [DISCUSS] Flink 1.6 features Wed, 06 Jun, 04:12
Yan Zhou [FDS Science]           Re: [DISCUSS] Flink 1.6 features Wed, 06 Jun, 04:23
Stephan Ewen             Re: [DISCUSS] Flink 1.6 features Fri, 08 Jun, 20:31
Elias Levy               Re: [DISCUSS] Flink 1.6 features Fri, 08 Jun, 21:58
Elias Levy                 Re: [DISCUSS] Flink 1.6 features Sun, 17 Jun, 00:07
sagar loke                   Re: [DISCUSS] Flink 1.6 features Sun, 17 Jun, 03:11
zhangminglei                     Re: [DISCUSS] Flink 1.6 features Sun, 17 Jun, 12:11
zhangminglei                       Re: [DISCUSS] Flink 1.6 features Sun, 17 Jun, 12:34
Will Du                         Re: [DISCUSS] Flink 1.6 features Sun, 17 Jun, 13:36
zhangminglei                           Re: [DISCUSS] Flink 1.6 features Sun, 17 Jun, 13:44
sagar loke                             Re: [DISCUSS] Flink 1.6 features Tue, 19 Jun, 01:10
zhangminglei                               Re: [DISCUSS] Flink 1.6 features Tue, 19 Jun, 01:30
sihua zhou               Re: [DISCUSS] Flink 1.6 features Sat, 09 Jun, 09:02
zhangminglei   Re: [DISCUSS] Flink 1.6 features Mon, 25 Jun, 02:45
makeyang why does flink release package preferred uber jar than small jar? Mon, 04 Jun, 10:39
Rong Rong   Re: why does flink release package preferred uber jar than small jar? Mon, 04 Jun, 20:37
makeyang     Re: why does flink release package preferred uber jar than small jar? Tue, 05 Jun, 02:07
Fabian Hueske       Re: why does flink release package preferred uber jar than small jar? Wed, 06 Jun, 10:48
Szczypiński, S. (Szymon) TaskManager use more memory than Xmx Mon, 04 Jun, 11:13
miki haiat   Re: TaskManager use more memory than Xmx Mon, 04 Jun, 11:20
Szczypiński, S. (Szymon)     ODP: TaskManager use more memory than Xmx Mon, 04 Jun, 11:23
Lasse Nedergaard       Re: ODP: TaskManager use more memory than Xmx Mon, 04 Jun, 11:29
Flavio Pompermaier         Re: ODP: TaskManager use more memory than Xmx Mon, 04 Jun, 12:24
Andrei Shumanski           Re: ODP: TaskManager use more memory than Xmx Mon, 04 Jun, 12:37
aitozi   Re: TaskManager use more memory than Xmx Mon, 04 Jun, 14:48
Fabian Hueske     Re: TaskManager use more memory than Xmx Wed, 06 Jun, 10:52
rakeshchalasani Cannot determine simple type name - [FLINK-7490] Mon, 04 Jun, 20:47
Chesnay Schepler   Re: Cannot determine simple type name - [FLINK-7490] Tue, 05 Jun, 06:06
Timo Walther     Re: Cannot determine simple type name - [FLINK-7490] Tue, 05 Jun, 09:05
rakeshchalasani       Re: Cannot determine simple type name - [FLINK-7490] Tue, 05 Jun, 15:32
Oleksandr Nitavskyi Output batch to Kafka Mon, 04 Jun, 22:39
Chesnay Schepler   Re: Output batch to Kafka Tue, 05 Jun, 06:10
Stephan Ewen     Re: Output batch to Kafka Tue, 05 Jun, 08:01
Re: NPE in flink sql over-window
Yan Zhou [FDS Science]   Re: NPE in flink sql over-window Mon, 04 Jun, 23:05
Yan Zhou [FDS Science]   Re: NPE in flink sql over-window Mon, 04 Jun, 23:26
Fabian Hueske     Re: NPE in flink sql over-window Tue, 05 Jun, 10:00
Renjie Liu [DISCUSS] FLIP-6 Problems Tue, 05 Jun, 02:43
Meghashyam Sandeep V flink-connector-cassandra for C* version > 3.0 Tue, 05 Jun, 05:57
Chesnay Schepler   Re: flink-connector-cassandra for C* version > 3.0 Tue, 05 Jun, 06:35
Re: Checkpointing when reading from files?
Fabian Hueske   Re: Checkpointing when reading from files? Tue, 05 Jun, 08:37
miki haiat Writing stream to Hadoop Tue, 05 Jun, 09:14
Marvin777   Re: Writing stream to Hadoop Tue, 05 Jun, 09:34
Kostas Kloudas   Re: Writing stream to Hadoop Tue, 05 Jun, 10:11
miki haiat     Re: Writing stream to Hadoop Tue, 05 Jun, 10:19
Chesnay Schepler       Re: Writing stream to Hadoop Tue, 05 Jun, 10:30
miki haiat         Re: Writing stream to Hadoop Tue, 05 Jun, 10:37
Data Engineer Checkpointing on cluster shutdown Tue, 05 Jun, 10:01
Chesnay Schepler   Re: Checkpointing on cluster shutdown Tue, 05 Jun, 10:49
Garvit Sharma     Re: Checkpointing on cluster shutdown Tue, 05 Jun, 11:06
Chesnay Schepler       Re: Checkpointing on cluster shutdown Tue, 05 Jun, 11:10
HarshithBolar How to read from Cassandra using Apache Flink? Tue, 05 Jun, 10:02
Chesnay Schepler   Re: How to read from Cassandra using Apache Flink? Tue, 05 Jun, 10:58
HarshithBolar     Re: How to read from Cassandra using Apache Flink? Wed, 06 Jun, 13:46
James (Jian Wu) [FDS Data Platform] Link checkpoint failure issue Tue, 05 Jun, 10:30
Chesnay Schepler   Re: Link checkpoint failure issue Tue, 05 Jun, 11:06
Sandybayev, Turar (CAI - Atlanta) Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 12:22
Garvit Sharma   Re: Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 12:44
Sandybayev, Turar (CAI - Atlanta)     Re: Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 20:18
Amit Jain   Re: Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 12:46
Aljoscha Krettek     Re: Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 16:05
Sandybayev, Turar (CAI - Atlanta)       Re: Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 20:47
Sandybayev, Turar (CAI - Atlanta)     Re: Implementing a “join” between a DataStream and a “set of rules” Tue, 05 Jun, 20:53
Fabian Hueske       Re: Implementing a “join” between a DataStream and a “set of rules” Wed, 06 Jun, 11:07
Re: PartitionNotFoundException after deployment
Nico Kruber   Re: PartitionNotFoundException after deployment Tue, 05 Jun, 13:30
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
May 2019335
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