flink-user mailing list archives: January 2017

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
ljwagerfield How do I ensure binary comparisons are being used? Sun, 01 Jan, 14:13
ljwagerfield   Re: How do I ensure binary comparisons are being used? Tue, 03 Jan, 06:53
Fabian Hueske     Re: How do I ensure binary comparisons are being used? Wed, 04 Jan, 12:37
ljwagerfield       Re: How do I ensure binary comparisons are being used? Thu, 05 Jan, 05:15
Re: Problem with JodaTime
Stephan Epping   Re: Problem with JodaTime Mon, 02 Jan, 07:39
Henri Heiskanen Flink streaming questions Mon, 02 Jan, 09:25
Jamie Grier   Re: Flink streaming questions Mon, 02 Jan, 20:20
Henri Heiskanen     Re: Flink streaming questions Tue, 03 Jan, 11:32
Fabian Hueske       Re: Flink streaming questions Wed, 04 Jan, 12:46
Henri Heiskanen         Re: Flink streaming questions Mon, 09 Jan, 20:52
Gwenhael Pasquiers Programmatically get live values of accumulators Mon, 02 Jan, 09:34
Jamie Grier   Re: Programmatically get live values of accumulators Mon, 02 Jan, 19:56
Gwenhael Pasquiers     RE: Programmatically get live values of accumulators Tue, 03 Jan, 09:16
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
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
Re: Events are assigned to wrong window
Nico   Re: Events are assigned to wrong window Mon, 02 Jan, 14:04
Aljoscha Krettek     Re: Events are assigned to wrong window Mon, 09 Jan, 15:10
Nico       Re: Events are assigned to wrong window Mon, 16 Jan, 11:18
Nico         Re: Events are assigned to wrong window Thu, 26 Jan, 18:17
Aljoscha Krettek           Re: Events are assigned to wrong window Fri, 27 Jan, 10:49
Nico             Re: Events are assigned to wrong window Fri, 27 Jan, 12:16
Aljoscha Krettek               Re: Events are assigned to wrong window Fri, 27 Jan, 14:16
Stephan Epping 1.1.4 IntelliJ Problem Mon, 02 Jan, 14:41
Kurt Young   Re: 1.1.4 IntelliJ Problem Tue, 03 Jan, 02:11
Stephan Epping     Re: 1.1.4 IntelliJ Problem Tue, 03 Jan, 08:48
Stephan Ewen       Re: 1.1.4 IntelliJ Problem Tue, 03 Jan, 21:06
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
Yury Ruchin           Re: 1.1.4 IntelliJ Problem Wed, 04 Jan, 12:17
Stephan Epping             Re: 1.1.4 IntelliJ Problem Thu, 05 Jan, 07:18
Re: Dynamic Scaling
Jamie Grier   Re: Dynamic Scaling Mon, 02 Jan, 19:48
Re: Set Parallelism and keyBy
Jamie Grier   Re: Set Parallelism and keyBy Mon, 02 Jan, 20:48
Hanna Prinz Speedup of Flink Applications Tue, 03 Jan, 11:25
Timur Shenkao   Re: Speedup of Flink Applications Tue, 03 Jan, 14:44
Fabian Hueske     Re: Speedup of Flink Applications Thu, 05 Jan, 10:32
Hanna Prinz       Re: Speedup of Flink Applications Thu, 05 Jan, 18:06
Robert Metzger [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 03 Jan, 12:43
Ted Yu   Re: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Wed, 04 Jan, 15:16
Robert Metzger   Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 10 Jan, 14:16
Fabian Hueske     Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Thu, 12 Jan, 08:56
Robert Metzger       Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Thu, 12 Jan, 10:24
Till Rohrmann         Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Thu, 12 Jan, 15:20
Chesnay Schepler           Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Thu, 12 Jan, 15:54
Till Rohrmann             Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Thu, 12 Jan, 16:45
Till Rohrmann               Re: some questions about submit flink job on flink-yarn Fri, 13 Jan, 10:21
Till Rohrmann                 Re: some questions about submit flink job on flink-yarn Sun, 15 Jan, 12:10
Fabian Hueske               Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Fri, 13 Jan, 10:29
Till Rohrmann                 Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Sun, 15 Jan, 19:23
Fabian Hueske                   Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Mon, 16 Jan, 11:13
Robert Metzger                     Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Mon, 23 Jan, 09:33
Robert Metzger                       Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 24 Jan, 11:14
Al-Isawi Rami Cannot run using a savepoint with the same jar Tue, 03 Jan, 22:44
Stephan Ewen   Re: Cannot run using a savepoint with the same jar Wed, 04 Jan, 09:19
Rami Al-Isawi     Re: Cannot run using a savepoint with the same jar Sat, 07 Jan, 11:36
Zhangrucong Does Flink cluster security works in Flink 1.1.4 release? Wed, 04 Jan, 06:25
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
Yassine MARZOUGUI     Re: Triggering a saveppoint failed the Job Thu, 05 Jan, 21:40
Konstantin Knauf Question about Scheduling of Batch Jobs Wed, 04 Jan, 12:30
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
Re: Reading worker-local input files
Robert Schmidtke   Re: Reading worker-local input files Wed, 04 Jan, 15:38
Re: Flink Checkpoint runs slow for low load stream
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
Chakravarthy varaga       Re: Flink Checkpoint runs slow for low load stream Thu, 05 Jan, 11:25
RE: Serializing NULLs
Newport, Billy   RE: Serializing NULLs Wed, 04 Jan, 18:25
Duck Shared Object Instance over different RichMapFunctions Wed, 04 Jan, 20:05
Aljoscha Krettek   Re: Shared Object Instance over different RichMapFunctions Mon, 09 Jan, 15:32
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
Mathias Peters     Re: Debugging Python-Api fails with NoClassDefFoundError Thu, 05 Jan, 07:25
Chesnay Schepler       Re: Debugging Python-Api fails with NoClassDefFoundError Thu, 05 Jan, 11:21
Shannon Carey Rapidly failing job eventually causes "Not enough free slots" Thu, 05 Jan, 00:21
Yury Ruchin   Re: Rapidly failing job eventually causes "Not enough free slots" Thu, 05 Jan, 12:15
Stephan Ewen     Re: Rapidly failing job eventually causes "Not enough free slots" Thu, 05 Jan, 13:52
Shannon Carey       Re: Rapidly failing job eventually causes "Not enough free slots" Sat, 21 Jan, 03:14
Shannon Carey         Re: Rapidly failing job eventually causes "Not enough free slots" Sat, 21 Jan, 03:31
Ufuk Celebi           Re: Rapidly failing job eventually causes "Not enough free slots" Sat, 21 Jan, 15:58
Stephan Ewen             Re: Rapidly failing job eventually causes "Not enough free slots" Tue, 24 Jan, 14:07
Shannon Carey               Re: Rapidly failing job eventually causes "Not enough free slots" Tue, 24 Jan, 17:16
Stephan Ewen                 Re: Rapidly failing job eventually causes "Not enough free slots" Wed, 25 Jan, 15:07
Hongyuhong Som question about Flink stream sql Thu, 05 Jan, 03:40
Fabian Hueske   Re: Som question about Flink stream sql Thu, 05 Jan, 09:42
Hongyuhong     答复: Som question about Flink stream sql Thu, 05 Jan, 11:00
Fabian Hueske       Re: 答复: Som question about Flink stream sql Thu, 05 Jan, 11:16
Jark Wu       Re: Som question about Flink stream sql Fri, 06 Jan, 03:01
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
ljwagerfield Are heterogeneous DataStreams possible? Thu, 05 Jan, 05:40
ljwagerfield   Re: Are heterogeneous DataStreams possible? Thu, 05 Jan, 05:44
Aljoscha Krettek     Re: Are heterogeneous DataStreams possible? Mon, 09 Jan, 15:35
Henri Heiskanen       Re: Are heterogeneous DataStreams possible? Mon, 09 Jan, 20:51
Sachin Goel Running into memory issues while running on Yarn Thu, 05 Jan, 08:54
Yury Ruchin   Re: Running into memory issues while running on Yarn Thu, 05 Jan, 13:24
Re: Caching collected objects in .apply()
Matt   Re: Caching collected objects in .apply() Thu, 05 Jan, 09:06
Fabian Hueske     Re: Caching collected objects in .apply() Thu, 05 Jan, 10:08
Aljoscha Krettek       Re: Caching collected objects in .apply() Mon, 09 Jan, 15:40
Sebastian Neef Sequential/ordered map Thu, 05 Jan, 10:51
Kostas Kloudas   Re: Sequential/ordered map 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
Sebastian Neef       Re: Sequential/ordered map Thu, 05 Jan, 12:18
Fabian Hueske         Re: Sequential/ordered map Thu, 05 Jan, 15:18
Abdul Salam Shaikh Regarding ordering of events Thu, 05 Jan, 10:57
Kostas Kloudas   Re: Regarding ordering of events Thu, 05 Jan, 11:16
Fabian Hueske     Re: Regarding ordering of events Thu, 05 Jan, 11:25
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
Aljoscha Krettek           Re: Regarding ordering of events Mon, 09 Jan, 15:52
Abdul Salam Shaikh             Re: Regarding ordering of events Mon, 09 Jan, 16:01
Re: High virtual memory usage
Paulo Cezar   Re: High virtual memory usage Thu, 05 Jan, 12:34
Stephan Ewen     Re: High virtual memory usage Thu, 05 Jan, 13:53
Chakravarthy varaga Increasing parallelism skews/increases overall job processing time linearly Thu, 05 Jan, 13:21
Chakravarthy varaga   Re: Increasing parallelism skews/increases overall job processing time linearly Fri, 06 Jan, 10:40
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
Chakravarthy varaga         Re: Increasing parallelism skews/increases overall job processing time linearly Sat, 07 Jan, 13:35
Chakravarthy varaga           Re: Increasing parallelism skews/increases overall job processing time linearly Mon, 09 Jan, 11:43
Chakravarthy varaga             Re: Increasing parallelism skews/increases overall job processing time linearly Tue, 10 Jan, 10:37
Till Rohrmann               Re: Increasing parallelism skews/increases overall job processing time linearly Wed, 11 Jan, 13:11
Chakravarthy varaga                 Re: Increasing parallelism skews/increases overall job processing time linearly Thu, 12 Jan, 11:12
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: Consistency guarantees on multiple sinks Thu, 05 Jan, 16:58
Kafka KeyedStream source
Niels Basjes   Kafka KeyedStream source Thu, 05 Jan, 17:37
Tzu-Li (Gordon) Tai     Re: Kafka KeyedStream source Mon, 09 Jan, 08:14
Niels Basjes       Re: Kafka KeyedStream source Wed, 11 Jan, 15:11
Tzu-Li (Gordon) Tai         Re: Kafka KeyedStream source Sun, 15 Jan, 20:48
Fabian Hueske           Re: Kafka KeyedStream source Mon, 16 Jan, 09:15
Niels Basjes             Re: Kafka KeyedStream source Wed, 18 Jan, 15:42
Fabian Hueske               Re: Kafka KeyedStream source Wed, 18 Jan, 16:26
Shannon Carey failure-rate restart strategy not working? Thu, 05 Jan, 19:50
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
Aljoscha Krettek       Re: failure-rate restart strategy not working? Mon, 09 Jan, 15:57
re: Does Flink cluster security works in Flink 1.1.4 release?
Zhangrucong   re: Does Flink cluster security works in Flink 1.1.4 release? Fri, 06 Jan, 03:19
Stephan Ewen     Re: Does Flink cluster security works in Flink 1.1.4 release? Fri, 06 Jan, 10:04
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
Jark Wu       Re: HashMap/HashSet Serialization Issue Sat, 07 Jan, 11:42
Charith Wickramarachchi         Re: HashMap/HashSet Serialization Issue Sat, 07 Jan, 20:09
tao xiao window function outputs two different values Sat, 07 Jan, 12:30
tao xiao   Re: window function outputs two different values Mon, 09 Jan, 14:27
Aljoscha Krettek     Re: window function outputs two different values Tue, 10 Jan, 14:43
Yury Ruchin       Re: window function outputs two different values Tue, 10 Jan, 15:28
Jonas keyBy called twice. Second time, INetAddress and Array[Byte] are empty Sun, 08 Jan, 02:28
Jonas   Re: keyBy called twice. Second time, INetAddress and Array[Byte] are empty Mon, 09 Jan, 17:46
Jamie Grier     Re: keyBy called twice. Second time, INetAddress and Array[Byte] are empty Tue, 10 Jan, 20:58
Jonas       Re: keyBy called twice. Second time, INetAddress and Array[Byte] are empty Fri, 20 Jan, 12:19
Malte Schwarzer Use Flink in Oozie Workflow Sun, 08 Jan, 12:01
Deepak Sharma   Re: Use Flink in Oozie Workflow Sun, 08 Jan, 12:43
Dawid Wysakowicz Queryable State Sun, 08 Jan, 15:43
Ufuk Celebi   Re: Queryable State Mon, 09 Jan, 09:47
Dawid Wysakowicz     Re: Queryable State Tue, 10 Jan, 18:43
Nico Kruber       Re: Queryable State Fri, 13 Jan, 17:50
Dawid Wysakowicz         Re: Queryable State Sat, 14 Jan, 13:03
Ufuk Celebi           Re: Queryable State Mon, 16 Jan, 12:19
Nico Kruber           Re: Queryable State Mon, 16 Jan, 12:25
Dawid Wysakowicz             Re: Queryable State Mon, 16 Jan, 13:47
Nico Kruber               Re: Queryable State Wed, 25 Jan, 13:47
Dawid Wysakowicz                 Re: Queryable State Fri, 27 Jan, 16:22
Re: Changing parallelism
abhishekrs   Re: Changing parallelism Sun, 08 Jan, 16:01
Fabian Hueske     Re: Changing parallelism Tue, 10 Jan, 08:28
igor.berman Joining two kafka streams Sun, 08 Jan, 20:06
Tzu-Li (Gordon) Tai   Re: Joining two kafka streams Mon, 09 Jan, 06:02
Igor Berman     Re: Joining two kafka streams Mon, 09 Jan, 18:34
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
May 2019316
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