flink-user mailing list archives: June 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Gábor Gévay Re: Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 13:13
Gábor Gévay Re: Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 14:48
Márton Balassi Re: Why would slot sharing be undesirable? Sat, 04 Jun, 10:16
Márton Balassi Re: Flink on YARN - how to resize a running cluster? Thu, 30 Jun, 10:47
iñaki williams Re: Result comparison from 2 DataStream Sources Thu, 02 Jun, 21:20
iñaki williams Custom keyBy(), look for similaties Mon, 06 Jun, 07:31
iñaki williams Re: Custom keyBy(), look for similaties Tue, 07 Jun, 08:48
iñaki williams Maxby() and KeyBy() question Thu, 09 Jun, 12:36
iñaki williams Re: Maxby() and KeyBy() question Thu, 09 Jun, 16:05
iñaki williams Re: Result comparison from 2 DataStream Sources Sun, 12 Jun, 13:06
笑傲风云 what is flink hardware require?? Tue, 14 Jun, 10:33
ANDREA SPINA Flink java.io.FileNotFoundException Exception with Peel Framework Tue, 28 Jun, 09:57
ANDREA SPINA Re: Flink java.io.FileNotFoundException Exception with Peel Framework Tue, 28 Jun, 10:17
ANDREA SPINA Re: Flink java.io.FileNotFoundException Exception with Peel Framework Wed, 29 Jun, 10:08
ANDREA SPINA Apache Flink 1.0.3 IllegalStateException Partiction State on chaining Wed, 29 Jun, 10:19
ANDREA SPINA Re: Apache Flink 1.0.3 IllegalStateException Partiction State on chaining Wed, 29 Jun, 13:10
Ahmed Nader com.esotericsoftware.kryo.KryoException and java.lang.IndexOutOfBoundsException Wed, 08 Jun, 13:40
Ahmed Nader Re: com.esotericsoftware.kryo.KryoException and java.lang.IndexOutOfBoundsException Wed, 08 Jun, 15:46
Ahmed Nader Re: com.esotericsoftware.kryo.KryoException and java.lang.IndexOutOfBoundsException Wed, 08 Jun, 15:48
Akshay Shingote (JIRA) [jira] Akshay Shingote shared "FLINK-4059: Requirement of Streaming layer for Complex Event Processing" with you Mon, 13 Jun, 12:36
Al-Isawi Rami Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 12:41
Al-Isawi Rami Re: Multi-field "sum" function just like "keyBy" Tue, 07 Jun, 14:18
Al-Isawi Rami Re: Multi-field "sum" function just like "keyBy" Wed, 08 Jun, 11:11
Alexis Gendronneau Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 00:05
Alexis Gendronneau Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] Wed, 01 Jun, 23:23
Alieh Saeedi Gelly scatter/gather Mon, 13 Jun, 16:06
Alieh Saeedi Gelly Scatter/Gather - Vertex update Tue, 14 Jun, 10:21
Alieh Saeedi Send to all in gelly scatter Tue, 14 Jun, 15:30
Alieh Saeedi LongMaxAggragator() Wed, 15 Jun, 08:52
Alieh Saeedi LongMaxAggregator in gelly scatter/gather Wed, 15 Jun, 08:58
Aljoscha Krettek Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 08:39
Aljoscha Krettek Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 09:50
Aljoscha Krettek Re: Maintaining watermarks per key, instead of per operator instance Wed, 01 Jun, 12:54
Aljoscha Krettek Re: Flink Kafka Consumer throwing Null Pointer Exception Thu, 02 Jun, 15:58
Aljoscha Krettek Re: No key found restore States Sat, 04 Jun, 05:49
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
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
Aljoscha Krettek Re: Periodically evicting internal states when using mapWithState() Tue, 07 Jun, 09:05
Aljoscha Krettek Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) Tue, 07 Jun, 12:50
Aljoscha Krettek Re: Window start and end issue with TumblingProcessingTimeWindows Tue, 07 Jun, 15:45
Aljoscha Krettek Re: Extracting Timestamp in MapFunction Thu, 09 Jun, 08:31
Aljoscha Krettek Re: Scala case classes with a generic parameter Thu, 09 Jun, 08:50
Aljoscha Krettek Re: Using Flink watermarks and a large window state for scheduling Thu, 09 Jun, 13:23
Aljoscha Krettek Re: NotSerializableException Thu, 09 Jun, 14:06
Aljoscha Krettek Re: NotSerializableException Fri, 10 Jun, 06:07
Aljoscha Krettek Re: Arrays values in keyBy Mon, 13 Jun, 09:19
Aljoscha Krettek Re: HBase reads and back pressure Mon, 13 Jun, 10:26
Aljoscha Krettek Re: NotSerializableException Mon, 13 Jun, 10:27
Aljoscha Krettek Re: Accessing StateBackend snapshots outside of Flink Mon, 13 Jun, 14:25
Aljoscha Krettek Re: Custom Barrier? Tue, 14 Jun, 08:32
Aljoscha Krettek Re: Custom Barrier? Wed, 15 Jun, 11:51
Aljoscha Krettek Re: Migrating from one state backend to another Wed, 15 Jun, 12:01
Aljoscha Krettek Re: Documentation for translation of Job graph to Execution graph Fri, 17 Jun, 09:31
Aljoscha Krettek Re: Kinesis connector classpath issue when running Flink 1.1-SNAPSHOT on YARN Fri, 17 Jun, 13:53
Aljoscha Krettek Re: Lazy Evaluation Tue, 21 Jun, 16:43
Aljoscha Krettek Re: Cassamdra Connector in Scala Tue, 21 Jun, 16:49
Aljoscha Krettek Re: TaskManager information during runtime Wed, 22 Jun, 13:09
Aljoscha Krettek Re: Code related to spilling data to disk Wed, 22 Jun, 13:11
Aljoscha Krettek Re: Kinesis connector classpath issue when running Flink 1.1-SNAPSHOT on YARN Thu, 23 Jun, 08:41
Aljoscha Krettek Re: Way to hold execution of one of the map operator in Co-FlatMaps Mon, 27 Jun, 09:02
Aljoscha Krettek Re: Way to hold execution of one of the map operator in Co-FlatMaps Mon, 27 Jun, 09:25
Aljoscha Krettek Re: Scala/ReactiveMongo: type classes, macros and java.util.Serializable Mon, 27 Jun, 12:34
Aljoscha Krettek Re: Way to hold execution of one of the map operator in Co-FlatMaps Tue, 28 Jun, 09:00
Aljoscha Krettek Re: maximum size of window Tue, 28 Jun, 09:04
Aljoscha Krettek Re: maximum size of window Wed, 29 Jun, 15:20
Aljoscha Krettek Re: How to count number of records received per second in processing time while using event time characteristic Wed, 29 Jun, 15:23
Aljoscha Krettek Re: Optimizations not performed - please confirm Wed, 29 Jun, 15:27
Aljoscha Krettek Re: Best way to read property file in flink Wed, 29 Jun, 15:29
Aljoscha Krettek Re: Question regarding logging capabilities in flink Thu, 30 Jun, 08:32
Aljoscha Krettek Re: How to avoid breaking states when upgrading Flink job? Thu, 30 Jun, 11:55
Aljoscha Krettek Re: Checkpointing very large state in RocksDB? Thu, 30 Jun, 12:07
Aljoscha Krettek Re: How to avoid breaking states when upgrading Flink job? Thu, 30 Jun, 12:27
Andrea Cisternino Reading whole files (from S3) Tue, 07 Jun, 14:35
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
Andrey Utkin /newbie/ Share state between streams Fri, 03 Jun, 16:34
Andrey Utkin Re: /newbie/ Share state between streams Sat, 04 Jun, 17:59
Anton Adding 3rd party moving average and other 'indicators' Fri, 24 Jun, 20:05
Ashutosh Kumar Re: Facing error while running Hands-in training example “writing to Apache Kafka” Wed, 01 Jun, 10:37
Ashutosh Kumar Re: Submit Flink Jobs to YARN running on AWS Tue, 07 Jun, 17:48
Bajaj, Abhinav Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 00:08
Bajaj, Abhinav Re: Submitting job via Flink web interface giving Null pointer exception Thu, 02 Jun, 22:28
Bajaj, Abhinav Re: Submit Flink Jobs to YARN running on AWS Mon, 06 Jun, 19:10
Bajaj, Abhinav Documentation for translation of Job graph to Execution graph Thu, 16 Jun, 17:31
Bajaj, Abhinav Re: Documentation for translation of Job graph to Execution graph Fri, 17 Jun, 23:41
Bajaj, Abhinav Re: Documentation for translation of Job graph to Execution graph Tue, 21 Jun, 23:15
Bajaj, Abhinav Re: Documentation for translation of Job graph to Execution graph Wed, 29 Jun, 19:19
Biplob Biswas Re: Extracting Timestamp in MapFunction Wed, 01 Jun, 14:33
Biplob Biswas Data Source Generator emits 4 instances of the same tuple Mon, 06 Jun, 08:30
Biplob Biswas Re: Data Source Generator emits 4 instances of the same tuple Mon, 06 Jun, 14:53
Biplob Biswas Re: Extracting Timestamp in MapFunction Thu, 09 Jun, 10:25
Biplob Biswas Re: Data Source Generator emits 4 instances of the same tuple Thu, 09 Jun, 22:28
Biplob Biswas Keeping latest data point in a data stream variable Tue, 21 Jun, 09:45
Biplob Biswas Way to hold execution of one of the map operator in Co-FlatMaps Sun, 26 Jun, 10:55
Biplob Biswas Re: Way to hold execution of one of the map operator in Co-FlatMaps Mon, 27 Jun, 15:16
Chesnay Schepler Re: Adding Context To Logs Thu, 02 Jun, 21:07
Chesnay Schepler Re: java.io.IOException: Couldn't access resultSet Sun, 05 Jun, 09:26
Chesnay Schepler Re: java.io.IOException: Couldn't access resultSet Mon, 06 Jun, 07:46
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Dec 2019284
Nov 2019527
Oct 2019542
Sep 2019534
Aug 2019627
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