flink-user mailing list archives: June 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Alexis Gendronneau Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 00:05
arpit srivastava Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 05:01
Aljoscha Krettek Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 08:39
ahmad Sa P Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 08:47
Maximilian Michels Re: Type of TypeVariable 'OT' in 'class org.apache.flink.api.common.io.RichInputFormat' could not be determined. Wed, 01 Jun, 08:51
Aljoscha Krettek Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 09:50
leon_mcl...@tutanota.com Internal buffers Wed, 01 Jun, 09:54
ahmad Sa P Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 10:07
Ashutosh Kumar Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 10:37
ahmad Sa P Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 10:46
Ufuk Celebi Re: Internal buffers Wed, 01 Jun, 11:06
ahmad Sa P Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 11:06
Maximilian Michels Re: Context-specific step function in Iteration Wed, 01 Jun, 12:46
Aljoscha Krettek Re: Maintaining watermarks per key, instead of per operator instance Wed, 01 Jun, 12:54
simon peyer No key found restore States Wed, 01 Jun, 13:06
Maximilian Michels Re: No key found restore States Wed, 01 Jun, 13:55
simon peyer Re: No key found restore States Wed, 01 Jun, 14:00
Maximilian Michels Re: No key found restore States Wed, 01 Jun, 14:29
Biplob Biswas Re: Extracting Timestamp in MapFunction Wed, 01 Jun, 14:33
Flavio Pompermaier Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Wed, 01 Jun, 15:44
prateekarora Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 15:46
David Kim Flink Kafka Unused Properties Log Warnings Wed, 01 Jun, 16:42
Shannon Carey API request to submit job takes over 1hr Wed, 01 Jun, 17:54
James Bucher Scala case classes with a generic parameter Wed, 01 Jun, 18:11
Ritesh Kumar Singh Submitting job via Flink web interface giving Null pointer exception Wed, 01 Jun, 18:11
Robert Metzger Re: Flink Kafka Unused Properties Log Warnings Wed, 01 Jun, 18:12
David Kim Re: Flink Kafka Unused Properties Log Warnings Wed, 01 Jun, 19:19
Konstantin Knauf Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 19:24
prateekarora Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 22:04
Alexis Gendronneau Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 23:23
Shannon Carey Re: API request to submit job takes over 1hr Wed, 01 Jun, 23:44
Bajaj, Abhinav Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 00:08
simon peyer Re: No key found restore States Thu, 02 Jun, 08:16
Robert Metzger Re: API request to submit job takes over 1hr Thu, 02 Jun, 09:19
simon peyer Re: No key found restore States Thu, 02 Jun, 09:40
Debaditya Roy Exception in thread main: No such exception errpr Thu, 02 Jun, 10:02
Ritesh Kumar Singh Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 10:28
Kostas Kloudas Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 11:27
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 12:01
Kostas Kloudas Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 12:17
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 12:55
Kostas Kloudas Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 13:07
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 13:13
leon_mcl...@tutanota.com Re: Maintaining watermarks per key, instead of per operator instance Thu, 02 Jun, 13:22
leon_mcl...@tutanota.com Re: Internal buffers Thu, 02 Jun, 13:26
Kostas Kloudas Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 13:32
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 13:54
Robert Metzger Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 14:10
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 14:19
Kostas Kloudas Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 14:32
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 14:36
Kostas Kloudas Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 15:35
Debaditya Roy Re: Exception in thread main: No such exception errpr Thu, 02 Jun, 15:53
Aljoscha Krettek Re: Flink Kafka Consumer throwing Null Pointer Exception Thu, 02 Jun, 15:58
Hamilton, Paul Adding Context To Logs Thu, 02 Jun, 16:53
Kanstantsin Kamkou Re: Maintaining watermarks per key, instead of per operator instance Thu, 02 Jun, 17:18
Kostas Kloudas Re: Adding Context To Logs Thu, 02 Jun, 20:39
Chesnay Schepler Re: Adding Context To Logs Thu, 02 Jun, 21:07
iñaki williams Re: Result comparison from 2 DataStream Sources Thu, 02 Jun, 21:20
Bajaj, Abhinav Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 22:28
Soumya Simanta S3 as streaming source Fri, 03 Jun, 05:22
Tzu-Li (Gordon) Tai Re: S3 as streaming source Fri, 03 Jun, 05:37
Chiwan Park Re: S3 as streaming source Fri, 03 Jun, 06:23
Tzu-Li (Gordon) Tai Re: S3 as streaming source Fri, 03 Jun, 06:55
Hironori Ogibayashi Re: Writing test for Flink streaming jobs Fri, 03 Jun, 06:58
Ufuk Celebi Re: S3 as streaming source Fri, 03 Jun, 10:27
Igor Berman Event processing time with lateness Fri, 03 Jun, 12:55
Kostas Kloudas Re: Event processing time with lateness Fri, 03 Jun, 13:47
Debaditya Roy Re: Exception in thread main: No such exception errpr Fri, 03 Jun, 14:23
Igor Berman Re: Event processing time with lateness Fri, 03 Jun, 14:40
Kostas Kloudas Re: Event processing time with lateness Fri, 03 Jun, 15:55
Andrey Utkin /newbie/ Share state between streams Fri, 03 Jun, 16:34
Michael Tamillow Re: Event processing time with lateness Fri, 03 Jun, 20:02
Jamie Grier Re: /newbie/ Share state between streams Fri, 03 Jun, 20:46
Elias Levy Kafka producer sink message loss? Sat, 04 Jun, 02:05
Aljoscha Krettek Re: No key found restore States Sat, 04 Jun, 05:49
leon_mcl...@tutanota.com Why would slot sharing be undesirable? Sat, 04 Jun, 08:09
Márton Balassi Re: Why would slot sharing be undesirable? Sat, 04 Jun, 10:16
Aljoscha Krettek Re: Maintaining watermarks per key, instead of per operator instance Sat, 04 Jun, 12:55
Aljoscha Krettek Re: Event processing time with lateness Sat, 04 Jun, 14:05
Dan Drewes env.fromElements produces TypeInformation error Sat, 04 Jun, 15:34
Simone Robutti Re: env.fromElements produces TypeInformation error Sat, 04 Jun, 17:38
Andrey Utkin Re: /newbie/ Share state between streams Sat, 04 Jun, 17:59
Dan Drewes Re: env.fromElements produces TypeInformation error Sat, 04 Jun, 18:04
David Olsen java.io.IOException: Couldn't access resultSet Sun, 05 Jun, 09:05
Chesnay Schepler Re: java.io.IOException: Couldn't access resultSet Sun, 05 Jun, 09:26
David Olsen Re: java.io.IOException: Couldn't access resultSet Sun, 05 Jun, 10:26
David Olsen Re: java.io.IOException: Couldn't access resultSet Sun, 05 Jun, 10:47
Stephan Ewen Re: java.io.IOException: Couldn't access resultSet Sun, 05 Jun, 17:33
Stephan Ewen Re: Kafka producer sink message loss? Sun, 05 Jun, 22:16
Aljoscha Krettek Re: env.fromElements produces TypeInformation error Mon, 06 Jun, 07:26
Aljoscha Krettek Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 07:27
iñaki williams Custom keyBy(), look for similaties Mon, 06 Jun, 07:31
Chesnay Schepler Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 07:46
Biplob Biswas Data Source Generator emits 4 instances of the same tuple Mon, 06 Jun, 08:30
Flavio Pompermaier Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Mon, 06 Jun, 08:31
Christophe Salperwyck HBase Input Format for streaming Mon, 06 Jun, 11:49
Sendoh Logs show `Marking the coordinator 2147483637 dead` in Flink-Kafka conn Mon, 06 Jun, 12:10
LINZ, Arnaud Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 06 Jun, 12:19
Ufuk Celebi Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 06 Jun, 12:37
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Jul 2019400
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