flink-user mailing list archives: January 2017

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
ljwagerfield How do I ensure binary comparisons are being used? Sun, 01 Jan, 14:13
Stephan Epping Re: Problem with JodaTime Mon, 02 Jan, 07:39
Henri Heiskanen Flink streaming questions Mon, 02 Jan, 09:25
Gwenhael Pasquiers Programmatically get live values of accumulators Mon, 02 Jan, 09:34
Sujit Sakre Hi, There is possibly an issue with EventTimeSessionWindows where a gap is specified for considering items in the same session. Here the logic is, if two adjacent items have a difference in event timestamps of more than the gap then the items are considered to be in separate session. The issue is, what happens if the gap between streaming records is never (or for a very long time) less than the session gap. This is likely to lead to a race condition. Is this a bug? How do we deal with this to process windows in finite time? Please could you suggest. Thanks. Mon, 02 Jan, 11:11
Nico Re: Events are assigned to wrong window Mon, 02 Jan, 14:04
Stephan Epping 1.1.4 IntelliJ Problem Mon, 02 Jan, 14:41
Jamie Grier Re: Dynamic Scaling Mon, 02 Jan, 19:48
Jamie Grier Re: Hi, There is possibly an issue with EventTimeSessionWindows where a gap is specified for considering items in the same session. Here the logic is, if two adjacent items have a difference in event timestamps of more than the gap then the items are considered to be in separate session. The issue is, what happens if the gap between streaming records is never (or for a very long time) less than the session gap. This is likely to lead to a race condition. Is this a bug? How do we deal with this to process windows in finite time? Please could you suggest. Thanks. Mon, 02 Jan, 19:54
Jamie Grier Re: Programmatically get live values of accumulators Mon, 02 Jan, 19:56
Jamie Grier Re: Flink streaming questions Mon, 02 Jan, 20:20
Jamie Grier Re: Set Parallelism and keyBy Mon, 02 Jan, 20:48
Kurt Young Re: 1.1.4 IntelliJ Problem Tue, 03 Jan, 02:11
ljwagerfield Re: How do I ensure binary comparisons are being used? Tue, 03 Jan, 06:53
Stephan Epping Re: 1.1.4 IntelliJ Problem Tue, 03 Jan, 08:48
Gwenhael Pasquiers RE: Programmatically get live values of accumulators Tue, 03 Jan, 09:16
Hanna Prinz Speedup of Flink Applications Tue, 03 Jan, 11:25
Henri Heiskanen Re: Flink streaming questions Tue, 03 Jan, 11:32
Robert Metzger [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 03 Jan, 12:43
Timur Shenkao Re: Speedup of Flink Applications Tue, 03 Jan, 14:44
Stephan Ewen Re: 1.1.4 IntelliJ Problem Tue, 03 Jan, 21:06
Al-Isawi Rami Cannot run using a savepoint with the same jar Tue, 03 Jan, 22:44
Zhangrucong Does Flink cluster security works in Flink 1.1.4 release? Wed, 04 Jan, 06:25
Stephan Epping Re: 1.1.4 IntelliJ Problem Wed, 04 Jan, 08:07
Stephan Epping Re: 1.1.4 IntelliJ Problem Wed, 04 Jan, 08:20
Stephan Ewen Re: Cannot run using a savepoint with the same jar Wed, 04 Jan, 09:19
Stephan Ewen Re: Does Flink cluster security works in Flink 1.1.4 release? Wed, 04 Jan, 09:23
Yassine MARZOUGUI Triggering a saveppoint failed the Job Wed, 04 Jan, 09:52
Stephan Ewen Re: Triggering a saveppoint failed the Job Wed, 04 Jan, 11:55
Yury Ruchin Re: 1.1.4 IntelliJ Problem Wed, 04 Jan, 12:17
Konstantin Knauf Question about Scheduling of Batch Jobs Wed, 04 Jan, 12:30
Fabian Hueske Re: How do I ensure binary comparisons are being used? Wed, 04 Jan, 12:37
Fabian Hueske Re: Flink streaming questions Wed, 04 Jan, 12:46
Fabian Hueske Re: Question about Scheduling of Batch Jobs Wed, 04 Jan, 13:15
Konstantin Knauf Re: Question about Scheduling of Batch Jobs Wed, 04 Jan, 14:40
Ted Yu Re: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Wed, 04 Jan, 15:16
Robert Schmidtke Re: Reading worker-local input files Wed, 04 Jan, 15:38
Chakravarthy varaga Re: Flink Checkpoint runs slow for low load stream Wed, 04 Jan, 15:51
Fabian Hueske Re: Flink Checkpoint runs slow for low load stream Wed, 04 Jan, 17:33
Newport, Billy RE: Serializing NULLs Wed, 04 Jan, 18:25
Duck Shared Object Instance over different RichMapFunctions Wed, 04 Jan, 20:05
Mathias Peters Debugging Python-Api fails with NoClassDefFoundError Wed, 04 Jan, 20:16
Ted Yu Re: Debugging Python-Api fails with NoClassDefFoundError Wed, 04 Jan, 20:52
Shannon Carey Rapidly failing job eventually causes "Not enough free slots" Thu, 05 Jan, 00:21
Hongyuhong Som question about Flink stream sql Thu, 05 Jan, 03:40
ljwagerfield Re: How do I ensure binary comparisons are being used? Thu, 05 Jan, 05:15
ljwagerfield Are heterogeneous DataStreams possible? Thu, 05 Jan, 05:40
ljwagerfield Re: Are heterogeneous DataStreams possible? Thu, 05 Jan, 05:44
Stephan Epping Re: 1.1.4 IntelliJ Problem Thu, 05 Jan, 07:18
Mathias Peters Re: Debugging Python-Api fails with NoClassDefFoundError Thu, 05 Jan, 07:25
Sachin Goel Running into memory issues while running on Yarn Thu, 05 Jan, 08:54
Matt Re: Caching collected objects in .apply() Thu, 05 Jan, 09:06
Fabian Hueske Re: Som question about Flink stream sql Thu, 05 Jan, 09:42
Fabian Hueske Re: Caching collected objects in .apply() Thu, 05 Jan, 10:08
Fabian Hueske Re: Speedup of Flink Applications Thu, 05 Jan, 10:32
Sebastian Neef Sequential/ordered map Thu, 05 Jan, 10:51
Abdul Salam Shaikh Regarding ordering of events Thu, 05 Jan, 10:57
Hongyuhong 答复: Som question about Flink stream sql Thu, 05 Jan, 11:00
Kostas Kloudas Re: Regarding ordering of events Thu, 05 Jan, 11:16
Fabian Hueske Re: 答复: Som question about Flink stream sql Thu, 05 Jan, 11:16
Chesnay Schepler Re: Debugging Python-Api fails with NoClassDefFoundError Thu, 05 Jan, 11:21
Kostas Kloudas Re: Sequential/ordered map Thu, 05 Jan, 11:25
Chakravarthy varaga Re: Flink Checkpoint runs slow for low load stream Thu, 05 Jan, 11:25
Fabian Hueske Re: Regarding ordering of events Thu, 05 Jan, 11:25
Sebastian Neef Re: Sequential/ordered map Thu, 05 Jan, 11:36
Chesnay Schepler Re: Sequential/ordered map Thu, 05 Jan, 11:39
Yury Ruchin Re: Rapidly failing job eventually causes "Not enough free slots" Thu, 05 Jan, 12:15
Sebastian Neef Re: Sequential/ordered map Thu, 05 Jan, 12:18
Paulo Cezar Re: High virtual memory usage Thu, 05 Jan, 12:34
Chakravarthy varaga Increasing parallelism skews/increases overall job processing time linearly Thu, 05 Jan, 13:21
Yury Ruchin Re: Running into memory issues while running on Yarn Thu, 05 Jan, 13:24
Nancy Estrada Consistency guarantees on multiple sinks Thu, 05 Jan, 13:24
Paris Carbone Re: Consistency guarantees on multiple sinks Thu, 05 Jan, 13:47
Stephan Ewen Re: Rapidly failing job eventually causes "Not enough free slots" Thu, 05 Jan, 13:52
Stephan Ewen Re: High virtual memory usage Thu, 05 Jan, 13:53
Fabian Hueske Re: Sequential/ordered map Thu, 05 Jan, 15:18
Stephan Ewen Re: Consistency guarantees on multiple sinks Thu, 05 Jan, 16:58
Niels Basjes Kafka KeyedStream source Thu, 05 Jan, 17:37
Hanna Prinz Re: Speedup of Flink Applications Thu, 05 Jan, 18:06
Shannon Carey failure-rate restart strategy not working? Thu, 05 Jan, 19:50
Abdul Salam Shaikh Re: Regarding ordering of events Thu, 05 Jan, 20:21
Kostas Kloudas Re: Regarding ordering of events Thu, 05 Jan, 20:55
Yassine MARZOUGUI Re: Triggering a saveppoint failed the Job Thu, 05 Jan, 21:40
Jark Wu Re: Som question about Flink stream sql Fri, 06 Jan, 03:01
Zhangrucong re: Does Flink cluster security works in Flink 1.1.4 release? Fri, 06 Jan, 03:19
Hongyuhong Re: Som question about Flink stream sql Fri, 06 Jan, 07:08
Jark Wu Re: Som question about Flink stream sql Fri, 06 Jan, 08:31
Stephan Ewen Re: Does Flink cluster security works in Flink 1.1.4 release? Fri, 06 Jan, 10:04
Chakravarthy varaga Re: Increasing parallelism skews/increases overall job processing time linearly Fri, 06 Jan, 10:40
Shannon Carey Re: failure-rate restart strategy not working? Fri, 06 Jan, 17:44
Stephan Ewen Re: failure-rate restart strategy not working? Fri, 06 Jan, 18:08
Chen Qin Re: Increasing parallelism skews/increases overall job processing time linearly Fri, 06 Jan, 18:27
Stephan Ewen Re: Increasing parallelism skews/increases overall job processing time linearly Fri, 06 Jan, 20:15
Charith Wickramarachchi HashMap/HashSet Serialization Issue Sat, 07 Jan, 02:06
Chen Qin Re: HashMap/HashSet Serialization Issue Sat, 07 Jan, 03:44
Charith Wickramarachchi Re: HashMap/HashSet Serialization Issue Sat, 07 Jan, 04:02
Rami Al-Isawi Re: Cannot run using a savepoint with the same jar Sat, 07 Jan, 11:36
Jark Wu Re: HashMap/HashSet Serialization Issue Sat, 07 Jan, 11:42
tao xiao window function outputs two different values Sat, 07 Jan, 12:30
Chakravarthy varaga Re: Increasing parallelism skews/increases overall job processing time linearly Sat, 07 Jan, 13:35
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
May 2019331
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