flink-user mailing list archives: June 2016

Site index · List index
Message list1 · 2 · 3 · Next »Thread · Author · Date
Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ]
Alexis Gendronneau   Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 00:05
prateekarora     Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 15:46
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
Re: Facing error while running Hands-in training example “writing to Apache Kafka”
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
Aljoscha Krettek         Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 09:50
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
ahmad Sa P               Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 11:06
Re: Type of TypeVariable 'OT' in 'class org.apache.flink.api.common.io.RichInputFormat' could not be determined.
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
Internal buffers
leon_mcl...@tutanota.com   Internal buffers Wed, 01 Jun, 09:54
Ufuk Celebi   Re: Internal buffers Wed, 01 Jun, 11:06
leon_mcl...@tutanota.com     Re: Internal buffers Thu, 02 Jun, 13:26
Aljoscha Krettek   Re: Maintaining watermarks per key, instead of per operator instance Wed, 01 Jun, 12:54
Kanstantsin Kamkou     Re: Maintaining watermarks per key, instead of per operator instance Thu, 02 Jun, 17:18
Aljoscha Krettek       Re: Maintaining watermarks per key, instead of per operator instance Sat, 04 Jun, 12:55
leon_mcl...@tutanota.com   Re: Maintaining watermarks per key, instead of per operator instance Thu, 02 Jun, 13:22
Re: Context-specific step function in Iteration
Maximilian Michels   Re: Context-specific step function in Iteration Wed, 01 Jun, 12:46
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
simon peyer         Re: No key found restore States Thu, 02 Jun, 08:16
simon peyer           Re: No key found restore States Thu, 02 Jun, 09:40
Aljoscha Krettek             Re: No key found restore States Sat, 04 Jun, 05:49
Re: Extracting Timestamp in MapFunction
Biplob Biswas   Re: Extracting Timestamp in MapFunction Wed, 01 Jun, 14:33
Aljoscha Krettek     Re: Extracting Timestamp in MapFunction Thu, 09 Jun, 08:31
Biplob Biswas       Re: Extracting Timestamp in MapFunction Thu, 09 Jun, 10:25
Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet)
Flavio Pompermaier   Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Wed, 01 Jun, 15:44
Flavio Pompermaier     Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Mon, 06 Jun, 08:31
Ufuk Celebi       Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Mon, 06 Jun, 14:08
Flavio Pompermaier         Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Tue, 07 Jun, 12:34
Aljoscha Krettek           Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Tue, 07 Jun, 12:50
Flavio Pompermaier             Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Tue, 07 Jun, 13:06
Flavio Pompermaier               Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Tue, 07 Jun, 13:21
David Kim Flink Kafka Unused Properties Log Warnings Wed, 01 Jun, 16:42
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
API request to submit job takes over 1hr
Shannon Carey   API request to submit job takes over 1hr Wed, 01 Jun, 17:54
Shannon Carey     Re: API request to submit job takes over 1hr Wed, 01 Jun, 23:44
Robert Metzger       Re: API request to submit job takes over 1hr Thu, 02 Jun, 09:19
Shannon Carey         Re: API request to submit job takes over 1hr Mon, 13 Jun, 20:58
Tzu-Li (Gordon) Tai           Re: API request to submit job takes over 1hr Tue, 14 Jun, 03:57
Robert Metzger             Re: API request to submit job takes over 1hr Wed, 15 Jun, 19:41
James Bucher Scala case classes with a generic parameter Wed, 01 Jun, 18:11
Aljoscha Krettek   Re: Scala case classes with a generic parameter Thu, 09 Jun, 08:50
Ritesh Kumar Singh Submitting job via Flink web interface giving Null pointer exception Wed, 01 Jun, 18:11
Bajaj, Abhinav   Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 00:08
Ritesh Kumar Singh     Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 10:28
Bajaj, Abhinav       Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 22:28
Debaditya Roy Exception in thread main: No such exception errpr Thu, 02 Jun, 10:02
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
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
Debaditya Roy                               Re: Exception in thread main: No such exception errpr Fri, 03 Jun, 14:23
Re: Flink Kafka Consumer throwing Null Pointer Exception
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
Kostas Kloudas   Re: Adding Context To Logs Thu, 02 Jun, 20:39
Chesnay Schepler     Re: Adding Context To Logs Thu, 02 Jun, 21:07
Re: Result comparison from 2 DataStream Sources
iñaki williams   Re: Result comparison from 2 DataStream Sources Thu, 02 Jun, 21:20
Konstantin Knauf     Re: Result comparison from 2 DataStream Sources Fri, 10 Jun, 14:01
iñaki williams       Re: Result comparison from 2 DataStream Sources Sun, 12 Jun, 13:06
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
Ufuk Celebi         Re: S3 as streaming source Fri, 03 Jun, 10:27
Re: Writing test for Flink streaming jobs
Hironori Ogibayashi   Re: Writing test for Flink streaming jobs Fri, 03 Jun, 06:58
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
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
Michael Tamillow         Re: Event processing time with lateness Fri, 03 Jun, 20:02
Aljoscha Krettek           Re: Event processing time with lateness Sat, 04 Jun, 14:05
Elias Levy     Re: Event processing time with lateness Mon, 06 Jun, 23:53
Andrey Utkin /newbie/ Share state between streams Fri, 03 Jun, 16:34
Jamie Grier   Re: /newbie/ Share state between streams Fri, 03 Jun, 20:46
Andrey Utkin     Re: /newbie/ Share state between streams Sat, 04 Jun, 17:59
Elias Levy Kafka producer sink message loss? Sat, 04 Jun, 02:05
Stephan Ewen   Re: Kafka producer sink message loss? Sun, 05 Jun, 22:16
Elias Levy     Re: Kafka producer sink message loss? Mon, 06 Jun, 21:58
Stephan Ewen       Re: Kafka producer sink message loss? Tue, 07 Jun, 11:52
Elias Levy         Re: Kafka producer sink message loss? Tue, 07 Jun, 14:52
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
env.fromElements produces TypeInformation error
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
Dan Drewes       Re: env.fromElements produces TypeInformation error Sat, 04 Jun, 18:04
Aljoscha Krettek         Re: env.fromElements produces TypeInformation error Mon, 06 Jun, 07:26
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
Aljoscha Krettek           Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 07:27
Chesnay Schepler             Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 07:46
David Olsen               Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 15:37
Chesnay Schepler                 Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 16:02
iñaki williams Custom keyBy(), look for similaties Mon, 06 Jun, 07:31
Ufuk Celebi   Re: Custom keyBy(), look for similaties Mon, 06 Jun, 14:12
iñaki williams     Re: Custom keyBy(), look for similaties Tue, 07 Jun, 08:48
Chesnay Schepler       Re: Custom keyBy(), look for similaties Wed, 08 Jun, 18:41
Biplob Biswas Data Source Generator emits 4 instances of the same tuple Mon, 06 Jun, 08:30
Ufuk Celebi   Re: Data Source Generator emits 4 instances of the same tuple Mon, 06 Jun, 14:09
Biplob Biswas     Re: Data Source Generator emits 4 instances of the same tuple Mon, 06 Jun, 14:53
Fabian Hueske       Re: Data Source Generator emits 4 instances of the same tuple Thu, 09 Jun, 15:12
Biplob Biswas         Re: Data Source Generator emits 4 instances of the same tuple Thu, 09 Jun, 22:28
Christophe Salperwyck HBase Input Format for streaming Mon, 06 Jun, 11:49
Ufuk Celebi   Re: HBase Input Format for streaming Mon, 06 Jun, 14:07
Christophe Salperwyck     Re: HBase Input Format for streaming Mon, 06 Jun, 15:21
Sendoh Logs show `Marking the coordinator 2147483637 dead` in Flink-Kafka conn Mon, 06 Jun, 12:10
Robert Metzger   Re: Logs show `Marking the coordinator 2147483637 dead` in Flink-Kafka conn Mon, 06 Jun, 14:05
Sendoh     Re: Logs show `Marking the coordinator 2147483637 dead` in Flink-Kafka conn Tue, 07 Jun, 09:08
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
LINZ, Arnaud     RE: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 06 Jun, 13:18
Ufuk Celebi       Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 06 Jun, 14:00
LINZ, Arnaud         RE: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 06 Jun, 15:52
LINZ, Arnaud         RE: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Wed, 15 Jun, 12:35
LINZ, Arnaud         RE: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Wed, 15 Jun, 13:14
Ufuk Celebi           Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Wed, 15 Jun, 15:54
Maximilian Michels           Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Wed, 15 Jun, 16:05
Maximilian Michels             Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Wed, 15 Jun, 17:00
LINZ, Arnaud             RE: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Thu, 16 Jun, 15:36
Till Rohrmann               Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Thu, 16 Jun, 16:01
Maximilian Michels                 Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 20 Jun, 09:09
Ufuk Celebi                   Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? Mon, 20 Jun, 12:23
Re: Submit Flink Jobs to YARN running on AWS
Josh   Re: Submit Flink Jobs to YARN running on AWS Mon, 06 Jun, 18:55
Bajaj, Abhinav     Re: Submit Flink Jobs to YARN running on AWS Mon, 06 Jun, 19:10
Shannon Carey       Re: Submit Flink Jobs to YARN running on AWS Tue, 07 Jun, 17:30
Ashutosh Kumar         Re: Submit Flink Jobs to YARN running on AWS Tue, 07 Jun, 17:48
Does Flink allows for encapsulation of transformations?
Ser Kho   Does Flink allows for encapsulation of transformations? Mon, 06 Jun, 19:14
Chesnay Schepler     Re: Does Flink allows for encapsulation of transformations? Tue, 07 Jun, 10:14
Ser Kho       Re: Does Flink allows for encapsulation of transformations? Tue, 07 Jun, 11:35
Chesnay Schepler         Re: Does Flink allows for encapsulation of transformations? Tue, 07 Jun, 12:14
Ser Kho           Re: Does Flink allows for encapsulation of transformations? Fri, 10 Jun, 00:46
Chesnay Schepler             Re: Does Flink allows for encapsulation of transformations? Fri, 10 Jun, 08:18
Greg Hogan     Re: Does Flink allows for encapsulation of transformations? Tue, 07 Jun, 12:18
Ser Kho       Re: Does Flink allows for encapsulation of transformations? Wed, 08 Jun, 02:01
Jack Huang Periodically evicting internal states when using mapWithState() Tue, 07 Jun, 01:04
Aljoscha Krettek   Re: Periodically evicting internal states when using mapWithState() Tue, 07 Jun, 09:05
Yukun Guo Hourly top-k statistics of DataStream Tue, 07 Jun, 02:26
Yukun Guo   Re: Hourly top-k statistics of DataStream Tue, 07 Jun, 02:33
Jamie Grier   Re: Hourly top-k statistics of DataStream Wed, 08 Jun, 00:04
Yukun Guo     Re: Hourly top-k statistics of DataStream Thu, 09 Jun, 13:29
Christophe Salperwyck       Re: Hourly top-k statistics of DataStream Thu, 09 Jun, 13:52
Philippe Caparroy       Re: Hourly top-k statistics of DataStream Thu, 09 Jun, 13:53
Soumya Simanta Window start and end issue with TumblingProcessingTimeWindows Tue, 07 Jun, 04:40
Chesnay Schepler   Re: Window start and end issue with TumblingProcessingTimeWindows Tue, 07 Jun, 10:17
Soumya Simanta     Re: Window start and end issue with TumblingProcessingTimeWindows Tue, 07 Jun, 12:56
Aljoscha Krettek       Re: Window start and end issue with TumblingProcessingTimeWindows Tue, 07 Jun, 15:45
Soumya Simanta         Re: Window start and end issue with TumblingProcessingTimeWindows Tue, 07 Jun, 15:59
Al-Isawi Rami Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 12:41
Gábor Gévay   Re: Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 13:13
Al-Isawi Rami     Re: Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 14:18
Gábor Gévay       Re: Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 14:48
Jamie Grier   Re: Multi-field "sum" function just like "keyBy" Wed, 08 Jun, 01:25
Al-Isawi Rami     Re: Multi-field "sum" function just like "keyBy" Wed, 08 Jun, 11:11
Andrea Cisternino Reading whole files (from S3) Tue, 07 Jun, 14:35
Jamie Grier   Re: Reading whole files (from S3) Wed, 08 Jun, 02:11
Suneel Marthi     Re: Reading whole files (from S3) Wed, 08 Jun, 02:23
Andrea Cisternino       Re: Reading whole files (from S3) Wed, 08 Jun, 06:16
Andrea Cisternino         Re: Reading whole files (from S3) Fri, 10 Jun, 08:53
Robert Metzger           Re: Reading whole files (from S3) Fri, 10 Jun, 12:10
Chris Wildman Event timestamps after data transformations Tue, 07 Jun, 18:43
Jamie Grier   Re: Event timestamps after data transformations Wed, 08 Jun, 00:27
Emanuele Cesena Uploaded jar disappears when web monitor restarts Wed, 08 Jun, 03:06
Till Rohrmann   Re: Uploaded jar disappears when web monitor restarts Wed, 08 Jun, 08:57
Emanuele Cesena     Re: Uploaded jar disappears when web monitor restarts Wed, 08 Jun, 17:00
Soumya Simanta Dedicated ExecutionContext inside Flink Wed, 08 Jun, 05:14
Till Rohrmann   Re: Dedicated ExecutionContext inside Flink Wed, 08 Jun, 09:10
Josh ClassCastException when redeploying Flink job on running cluster Wed, 08 Jun, 08:38
Till Rohrmann   Re: ClassCastException when redeploying Flink job on running cluster Wed, 08 Jun, 10:23
Josh     Re: ClassCastException when redeploying Flink job on running cluster Wed, 08 Jun, 14:19
Josh       Re: ClassCastException when redeploying Flink job on running cluster Wed, 08 Jun, 14:24
Till Rohrmann         Re: ClassCastException when redeploying Flink job on running cluster Wed, 08 Jun, 15:41
Josh           Re: ClassCastException when redeploying Flink job on running cluster Wed, 08 Jun, 17:45
Till Rohrmann             Re: ClassCastException when redeploying Flink job on running cluster Thu, 09 Jun, 07:49
Message list1 · 2 · 3 · Next »Thread · Author · Date
Box list
Aug 2019510
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