flink-user mailing list archives: September 2016

Site index · List index
Message list1 · 2 · 3 · Next »Thread · Author · Date
NoClassDefFoundError with ElasticsearchSink on Yarn
Hausmann, Steffen   NoClassDefFoundError with ElasticsearchSink on Yarn Thu, 01 Sep, 08:45
Fabian Hueske     Re: NoClassDefFoundError with ElasticsearchSink on Yarn Thu, 01 Sep, 09:01
Steffen Hausmann   NoClassDefFoundError with ElasticsearchSink on Yarn Thu, 01 Sep, 08:58
aris kol     Re: NoClassDefFoundError with ElasticsearchSink on Yarn Thu, 01 Sep, 10:22
Steffen Hausmann       Re: NoClassDefFoundError with ElasticsearchSink on Yarn Mon, 05 Sep, 20:26
Robert Metzger         Re: NoClassDefFoundError with ElasticsearchSink on Yarn Fri, 09 Sep, 09:49
Fabian Hueske           Re: NoClassDefFoundError with ElasticsearchSink on Yarn Fri, 09 Sep, 09:55
Re: Wikiedit QuickStart with Kinesis
Tzu-Li (Gordon) Tai   Re: Wikiedit QuickStart with Kinesis Thu, 01 Sep, 09:25
Foster, Craig     Re: Wikiedit QuickStart with Kinesis Thu, 01 Sep, 14:43
Tzu-Li Tai       Re: Wikiedit QuickStart with Kinesis Thu, 01 Sep, 17:37
Foster, Craig         Re: Wikiedit QuickStart with Kinesis Thu, 01 Sep, 17:48
Re: CountTrigger FIRE or FIRE_AND_PURGE
Fabian Hueske   Re: CountTrigger FIRE or FIRE_AND_PURGE Thu, 01 Sep, 09:42
Re: FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null
ANDREA SPINA   Re: FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null Thu, 01 Sep, 09:56
Stefan Richter     Re: FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null Fri, 02 Sep, 08:51
ANDREA SPINA       Re: FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null Fri, 02 Sep, 09:30
ANDREA SPINA         Re: FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null Wed, 07 Sep, 09:57
Till Rohrmann           Re: FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null Wed, 07 Sep, 11:41
Stefan Richter Queryable state deactivated on current master branch Thu, 01 Sep, 12:20
vinay patil Re: Streaming - memory management Thu, 01 Sep, 14:13
Fabian Hueske   Re: Streaming - memory management Thu, 01 Sep, 15:21
vinay patil     Re: Streaming - memory management Thu, 01 Sep, 16:29
Fabian Hueske       Re: Streaming - memory management Thu, 01 Sep, 16:40
vinay patil         Re: Streaming - memory management Thu, 01 Sep, 17:55
Fabian Hueske           Re: Streaming - memory management Thu, 01 Sep, 18:13
vinay patil             Re: Streaming - memory management Thu, 01 Sep, 18:22
Fabian Hueske               Re: Streaming - memory management Thu, 01 Sep, 18:39
vinay patil                 Re: Streaming - memory management Thu, 01 Sep, 18:53
Fabian Hueske                   Re: Streaming - memory management Thu, 15 Sep, 18:41
Supun Kamburugamuve Nested iterations Thu, 01 Sep, 16:09
Gábor Gévay   Re: Nested iterations Thu, 01 Sep, 16:28
Supun Kamburugamuve     Re: Nested iterations Thu, 01 Sep, 16:31
Gábor Gévay       Re: Nested iterations Thu, 01 Sep, 16:57
Supun Kamburugamuve         Re: Nested iterations Thu, 01 Sep, 17:01
Paul Joireman Windows and Watermarks Clarification Thu, 01 Sep, 18:16
Fabian Hueske   Re: Windows and Watermarks Clarification Thu, 01 Sep, 18:25
Paul Joireman   Re: Windows and Watermarks Clarification Thu, 01 Sep, 18:42
Fabian Hueske     Re: Windows and Watermarks Clarification Thu, 01 Sep, 19:15
Aljoscha Krettek       Re: Windows and Watermarks Clarification Fri, 02 Sep, 05:54
Re: Cannot pass objects with null-valued fields to the next operator
Jack Huang   Re: Cannot pass objects with null-valued fields to the next operator Thu, 01 Sep, 20:53
Re: Handle deserialization error
Jack Huang   Re: Handle deserialization error Thu, 01 Sep, 20:58
Jack Huang Metrics not reported to graphite Thu, 01 Sep, 21:07
Greg Hogan   Re: Metrics not reported to graphite Thu, 01 Sep, 22:04
Jack Huang     Re: Metrics not reported to graphite Thu, 01 Sep, 22:46
Jack Huang       Re: Metrics not reported to graphite Thu, 01 Sep, 22:56
Re: Firing windows multiple times
Aljoscha Krettek   Re: Firing windows multiple times Fri, 02 Sep, 09:02
Shannon Carey     Re: Firing windows multiple times Fri, 02 Sep, 17:44
Aljoscha Krettek       Re: Firing windows multiple times Mon, 05 Sep, 14:24
aj.h     Re: Firing windows multiple times Mon, 12 Sep, 02:59
Aljoscha Krettek       Re: Firing windows multiple times Wed, 14 Sep, 08:10
aj.h   Re: Firing windows multiple times Thu, 08 Sep, 19:45
Aljoscha Krettek     Re: Firing windows multiple times Fri, 09 Sep, 08:29
Vishnu Viswanath       Re: Firing windows multiple times Fri, 09 Sep, 17:41
Bauss, Julian Storing JPMML-Model Object as a Variable Closure? Fri, 02 Sep, 09:20
Stephan Ewen   Re: Storing JPMML-Model Object as a Variable Closure? Fri, 02 Sep, 13:26
Bauss, Julian     AW: Storing JPMML-Model Object as a Variable Closure? Mon, 05 Sep, 12:11
Simone Robutti       Re: Storing JPMML-Model Object as a Variable Closure? Mon, 05 Sep, 12:59
Bauss, Julian         AW: Storing JPMML-Model Object as a Variable Closure? Mon, 05 Sep, 13:24
Simone Robutti           Re: Storing JPMML-Model Object as a Variable Closure? Mon, 05 Sep, 13:41
Bauss, Julian             AW: Storing JPMML-Model Object as a Variable Closure? Mon, 05 Sep, 14:33
Simone Robutti               Re: Storing JPMML-Model Object as a Variable Closure? Mon, 05 Sep, 14:53
Dan Drewes Flink Iterations vs. While loop Fri, 02 Sep, 10:16
Greg Hogan   Re: Flink Iterations vs. While loop Fri, 02 Sep, 14:39
Dan Drewes     Re: Flink Iterations vs. While loop Fri, 02 Sep, 15:30
Theodore Vasiloudis       Re: Flink Iterations vs. While loop Mon, 05 Sep, 14:10
Dan Drewes         Re: Flink Iterations vs. While loop Tue, 06 Sep, 14:20
Greg Hogan       Re: Flink Iterations vs. While loop Tue, 06 Sep, 14:55
Theodore Vasiloudis         Re: Flink Iterations vs. While loop Tue, 06 Sep, 16:50
Till Rohrmann           Re: Flink Iterations vs. While loop Wed, 07 Sep, 08:23
Dan Drewes             Re: Flink Iterations vs. While loop Wed, 07 Sep, 13:43
Till Rohrmann               Re: Flink Iterations vs. While loop Wed, 07 Sep, 15:25
Drewes, Dan Benedikt                 Re: Flink Iterations vs. While loop Fri, 09 Sep, 20:47
Dong-iL, Kim checkpoints not removed on hdfs. Fri, 02 Sep, 10:17
Aljoscha Krettek   Re: checkpoints not removed on hdfs. Mon, 05 Sep, 09:29
Ufuk Celebi     Re: checkpoints not removed on hdfs. Wed, 28 Sep, 08:00
jiecxy Apache Flink: How does it handle the backpressure? Fri, 02 Sep, 12:07
rss rss   Re: Apache Flink: How does it handle the backpressure? Fri, 02 Sep, 19:56
Aljoscha Krettek     Re: Apache Flink: How does it handle the backpressure? Mon, 05 Sep, 09:25
Paul Wilson Remote upload and execute Fri, 02 Sep, 12:38
Aljoscha Krettek   Re: Remote upload and execute Mon, 05 Sep, 09:30
Maximilian Michels   Re: Remote upload and execute Mon, 05 Sep, 10:37
Maximilian Michels [DISCUSS] Storm 1.x.x support in the compatibility layer Fri, 02 Sep, 13:25
Re: How to get latency info from benchmark
Eric Fukuda   Re: How to get latency info from benchmark Fri, 02 Sep, 15:09
Robert Metzger     Re: How to get latency info from benchmark Fri, 02 Sep, 16:01
Eric Fukuda       Re: How to get latency info from benchmark Fri, 02 Sep, 19:12
Robert Metzger         Re: How to get latency info from benchmark Sat, 03 Sep, 11:41
Eric Fukuda           Re: How to get latency info from benchmark Sat, 03 Sep, 19:15
Luis Mariano Guerra emit a single Map<String, T> per window Fri, 02 Sep, 15:37
Aljoscha Krettek   Re: emit a single Map<String, T> per window Fri, 02 Sep, 16:24
Luis Mariano Guerra     Re: emit a single Map<String, T> per window Fri, 02 Sep, 16:26
Aljoscha Krettek       Re: emit a single Map<String, T> per window Mon, 05 Sep, 11:30
Luis Mariano Guerra         Re: emit a single Map<String, T> per window Mon, 05 Sep, 15:35
Aljoscha Krettek           Re: emit a single Map<String, T> per window Tue, 06 Sep, 08:38
Shaosu Liu Memory Management in Streaming? Fri, 02 Sep, 20:45
Stefan Richter   Re: Memory Management in Streaming? Sat, 03 Sep, 07:16
Jamie Grier   Re: Memory Management in Streaming? Sat, 03 Sep, 22:55
rimin...@sina.cn fromParallelCollection Sat, 03 Sep, 03:01
Maximilian Michels   Re: fromParallelCollection Mon, 05 Sep, 08:57
Re: Flink Kafka more consumers than partitions
neo21 zerro   Re: Flink Kafka more consumers than partitions Sat, 03 Sep, 10:42
Maximilian Michels     Re: Flink Kafka more consumers than partitions Mon, 05 Sep, 08:54
dbciar Kafka SimpleStringConsumer NPE Sat, 03 Sep, 23:14
Tzu-Li (Gordon) Tai   Re: Kafka SimpleStringConsumer NPE Sun, 04 Sep, 12:46
Maximilian Michels     Re: Kafka SimpleStringConsumer NPE Mon, 05 Sep, 15:08
Vishnu Viswanath [SUGGESTION] Stack Overflow Documentation for Apache Flink Sun, 04 Sep, 18:11
Maximilian Michels   Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 08:52
Ravikumar Hawaldar     Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 10:22
Fabian Hueske       Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 10:42
Maximilian Michels         Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 11:09
Till Rohrmann           Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 11:25
Matthias J. Sax             Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 11:44
Robert Metzger               Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Mon, 05 Sep, 13:37
Vishnu Viswanath                 Re: [SUGGESTION] Stack Overflow Documentation for Apache Flink Tue, 06 Sep, 02:10
Re: flink dataStream operate dataSet
Aljoscha Krettek   Re: flink dataStream operate dataSet Mon, 05 Sep, 09:21
CPC fsbackend with nfs Mon, 05 Sep, 12:11
Robert Metzger   Re: fsbackend with nfs Wed, 07 Sep, 16:23
RawSchema as deserialization schema
Swapnil Chougule   RawSchema as deserialization schema Mon, 05 Sep, 13:50
Maximilian Michels     Re: RawSchema as deserialization schema Mon, 05 Sep, 15:18
Swapnil Chougule       Re: RawSchema as deserialization schema Mon, 12 Sep, 06:12
Swapnil Chougule         Re: RawSchema as deserialization schema Thu, 22 Sep, 13:17
Stephan Ewen           Re: RawSchema as deserialization schema Thu, 22 Sep, 13:42
Swapnil Chougule             Re: RawSchema as deserialization schema Mon, 26 Sep, 09:27
Robert Metzger               Re: RawSchema as deserialization schema Mon, 26 Sep, 09:38
Swapnil Chougule                 Re: RawSchema as deserialization schema Mon, 26 Sep, 10:06
Chakravarthy varaga Sharing Java Collections within Flink Cluster Mon, 05 Sep, 15:51
Chakravarthy varaga   Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 15:49
Fabian Hueske     Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 16:00
Chakravarthy varaga       Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 17:07
Fabian Hueske         Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 17:33
Chakravarthy varaga           Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 17:55
Fabian Hueske             Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 18:44
Chakravarthy varaga               Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 19:45
Fabian Hueske                 Re: Sharing Java Collections within Flink Cluster Wed, 07 Sep, 20:15
Chakravarthy varaga                   Re: Sharing Java Collections within Flink Cluster Thu, 08 Sep, 18:24
Fabian Hueske                     Re: Sharing Java Collections within Flink Cluster Thu, 08 Sep, 21:10
Chakravarthy varaga                       Re: Sharing Java Collections within Flink Cluster Mon, 12 Sep, 14:24
Aljoscha Krettek                         Re: Sharing Java Collections within Flink Cluster Tue, 13 Sep, 06:29
Chakravarthy varaga                           Re: Sharing Java Collections within Flink Cluster Thu, 22 Sep, 14:38
Chakravarthy varaga                             Re: Sharing Java Collections within Flink Cluster Thu, 22 Sep, 14:57
Chakravarthy varaga                               Re: Sharing Java Collections within Flink Cluster Thu, 22 Sep, 19:22
pushpendra.jaiswal               Re: Sharing Java Collections within Flink Cluster Thu, 08 Sep, 06:54
Fabian Hueske                 Re: Sharing Java Collections within Flink Cluster Thu, 08 Sep, 07:05
rimin...@sina.cn 回复:Re: fromParallelCollection Tue, 06 Sep, 07:46
Timo Walther   Re: 回复:Re: fromParallelCollection Tue, 06 Sep, 09:03
rimin...@sina.cn modify coGroup GlobalWindows GlobalWindow Tue, 06 Sep, 08:05
Timo Walther   Re: modify coGroup GlobalWindows GlobalWindow Tue, 06 Sep, 09:44
rimin...@sina.cn 回复:Re: modify coGroup GlobalWindows GlobalWindow Tue, 06 Sep, 11:15
Timo Walther   Re: 回复:Re: modify coGroup GlobalWindows GlobalWindow Tue, 06 Sep, 12:52
jiecxy Stream sql query in Flink Tue, 06 Sep, 11:47
Timo Walther   Re: Stream sql query in Flink Tue, 06 Sep, 12:31
Timo Walther     Re: Stream sql query in Flink Fri, 16 Sep, 10:55
rimin...@sina.cn 回复:Re: 回复:Re: fromParallelCollection Tue, 06 Sep, 12:56
Timo Walther   Re: 回复:Re: 回复:Re: fromParallelCollection Wed, 07 Sep, 08:01
rimin...@sina.cn 回复:Re: 回复:Re: modify coGroup GlobalWindows_GlobalWindow Tue, 06 Sep, 13:53
Till Rohrmann   Re: Re: 回复:Re: modify coGroup GlobalWindows_GlobalWindow Wed, 07 Sep, 07:59
Re: Not able to query : Queryable State
pushpendra.jaiswal   Re: Not able to query : Queryable State Wed, 07 Sep, 05:44
pushpendra.jaiswal   Re: Not able to query : Queryable State Wed, 07 Sep, 06:07
Till Rohrmann     Re: Not able to query : Queryable State Wed, 07 Sep, 08:07
jiecxy How to assign timestamp for event time in a stream? Wed, 07 Sep, 10:15
Till Rohrmann   Re: How to assign timestamp for event time in a stream? Wed, 07 Sep, 11:57
Gyula Fóra Exception in CEP 1.1.2 Wed, 07 Sep, 14:43
Till Rohrmann   Re: Exception in CEP 1.1.2 Wed, 07 Sep, 15:34
Gyula Fóra     Re: Exception in CEP 1.1.2 Wed, 07 Sep, 15:37
Gyula Fóra       Re: Exception in CEP 1.1.2 Wed, 07 Sep, 20:05
Gyula Fóra         Re: Exception in CEP 1.1.2 Fri, 09 Sep, 07:59
Till Rohrmann           Re: Exception in CEP 1.1.2 Fri, 09 Sep, 08:30
Dong-iL, Kim assignTimestamp after keyBy Thu, 08 Sep, 03:59
pushpendra.jaiswal   Re: assignTimestamp after keyBy Thu, 08 Sep, 06:12
Dong-iL, Kim     Re: assignTimestamp after keyBy Thu, 08 Sep, 07:32
Dong-iL, Kim       Re: assignTimestamp after keyBy Thu, 08 Sep, 07:50
Fabian Hueske       Re: assignTimestamp after keyBy Thu, 08 Sep, 07:51
Pushpendra Jaiswal Unable to find KvState flink Queryablestate Thu, 08 Sep, 06:08
Robert Metzger   Re: Unable to find KvState flink Queryablestate Fri, 09 Sep, 09:57
Message list1 · 2 · 3 · Next »Thread · Author · Date
Box list
Sep 2018632
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